vanitasvitae/Smack
1
0
Fork 0
mirror of https://github.com/vanitasvitae/Smack.git synced 2025-09-10 01:29:38 +02:00
Code Issues Releases Wiki Activity

References to PacketWriterListener changed to PacketListener

Browse source 
git-svn-id: http://svn.igniterealtime.org/svn/repos/smack/trunk@2172 b35dd754-fafc-0310-a699-88a17e54d16e
This commit is contained in:
Gaston Dombiak 2003-11-18 17:06:47 +00:00 • committed by gdombiak
parent 4a8060c209
commit 7d7c02b750
6 changed files with 75 additions and 110 deletions
Download patch file Download diff file Expand all files Collapse all files

62
source/org/jivesoftware/smack/PacketWriter.java
View file

@ -55,6 +55,7 @@ package org.jivesoftware.smack;
import java.util.*;
import java.io.*;
import org.jivesoftware.smack.filter.PacketFilter;
import org.jivesoftware.smack.packet.Packet;
/**
@ -122,25 +123,27 @@ class PacketWriter {
}
/**
* Registers a packet writer listener with this writer. The listener will be
* notified of every packet that this writer sends.
* Registers a packet listener with this writer. The listener will be
* notified of every packet that this writer sends. A packet filter determines
* which packets will be delivered to the listener.
*
* @param packetWriterListener the packet writer listener to notify of sent packets.
* @param packetListener the packet listener to notify of sent packets.
* @param packetFilter the packet filter to use.
*/
public void addPacketListener(PacketWriterListener packetWriterListener) {
public void addPacketListener(PacketListener packetListener, PacketFilter packetFilter) {
synchronized (listeners) {
listeners.add(packetWriterListener);
listeners.add(new ListenerWrapper(packetListener, packetFilter));
}
}
/**
* Removes a packet writer listener.
* Removes a packet listener.
*
* @param packetWriterListener the packet writer listener to remove.
* @param packetListener the packet listener to remove.
*/
public void removePacketListener(PacketWriterListener packetWriterListener) {
public void removePacketListener(PacketListener packetListener) {
synchronized (listeners) {
listeners.remove(packetWriterListener);
listeners.remove(packetListener);
}
}
@ -236,11 +239,46 @@ class PacketWriter {
// Notify the listeners of the new sent packet
int size = listeners.size();
for (int i=0; i<size; i++) {
PacketWriterListener packetWriterListener = (PacketWriterListener)listeners.get(i);
if (packetWriterListener != null) {
packetWriterListener.processPacket(sentPacket);
ListenerWrapper listenerWrapper = (ListenerWrapper)listeners.get(i);
if (listenerWrapper != null) {
listenerWrapper.notifyListener(sentPacket);
}
}
}
}
/**
* A wrapper class to associate a packet filter with a listener.
*/
private static class ListenerWrapper {
private PacketListener packetListener;
private PacketFilter packetFilter;
public ListenerWrapper(PacketListener packetListener,
PacketFilter packetFilter)
{
this.packetListener = packetListener;
this.packetFilter = packetFilter;
}
public boolean equals(Object object) {
if (object == null) {
return false;
}
if (object instanceof ListenerWrapper) {
return ((ListenerWrapper)object).packetListener.equals(this.packetListener);
}
else if (object instanceof PacketListener) {
return object.equals(this.packetListener);
}
return false;
}
public void notifyListener(Packet packet) {
if (packetFilter == null || packetFilter.accept(packet)) {
packetListener.processPacket(packet);
}
}
}
}