tigase.xmpp
Class XMPPIOService<RefObject>

java.lang.Object
  extended by tigase.net.IOService<RefObject>
      extended by tigase.xmpp.XMPPIOService<RefObject>
Type Parameters:
RefObject - is a refrence object stored by this service. This is e reference to higher level data object keeping more information about the connection.
All Implemented Interfaces:
Callable<IOService>
Direct Known Subclasses:
BoshIOService

public class XMPPIOService<RefObject>
extends IOService<RefObject>

Describe class XMPPIOService here. Created: Tue Feb 7 07:15:02 2006

Version:
$Rev: 2148 $
Author:
Artur Hefczyc

Field Summary
protected  tigase.xml.SimpleParser parser
           
 
Fields inherited from class tigase.net.IOService
empty_read_call_count, HOSTNAME_KEY, PORT_TYPE_PROP_KEY, SESSION_ID_KEY
 
Constructor Summary
XMPPIOService()
          Creates a new XMPPIOService instance.
 
Method Summary
 void addPacketToSend(Packet packet)
          Method addPacketToSend adds new data which will be processed during next run.
protected  void addReceivedPacket(Packet packet)
          Method addReceivedPacket puts processing results to queue.
 Queue<Packet> getReceivedPackets()
          Method description
 String getXMLNS()
          Method description
 boolean isAuthenticated()
          Method description
protected  void processSocketData()
          Describe processSocketData method here.
 void processWaitingPackets()
          Describe processWaitingPackets method here.
protected  int receivedPackets()
           
 void setAuthenticated(boolean authenticated)
          Method description
 void setIOServiceListener(XMPPIOServiceListener sl)
          Method description
 void setXMLNS(String xmlns)
          Method description
 void stop()
          Describe stop method here.
 void writeRawData(String data)
          Method description
protected  void xmppStreamClosed()
           
 void xmppStreamOpen(String data)
          Method description
protected  void xmppStreamOpened(Map<String,String> attribs)
           
 
Methods inherited from class tigase.net.IOService
accept, call, connectionType, debug, debug, forceStop, getDataReceiver, getLastTransferTime, getLocalAddress, getReadCounters, getRefObject, getRemoteAddress, getSessionData, getSocketChannel, getStatistics, getUniqueId, getWriteCounters, isConnected, readCompleted, readData, setDataReceiver, setIOServiceListener, setRefObject, setSessionData, setSSLId, startSSL, startTLS, startZLib, toString, waitingToSend, waitingToSendSize, writeData
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

parser

protected tigase.xml.SimpleParser parser
Constructor Detail

XMPPIOService

public XMPPIOService()
Creates a new XMPPIOService instance.

Method Detail

addPacketToSend

public void addPacketToSend(Packet packet)
Method addPacketToSend adds new data which will be processed during next run. Data are kept in proper order like in FIFO queue.

Parameters:
packet - a Packet value of data to process.

getReceivedPackets

public Queue<Packet> getReceivedPackets()
Method description

Returns:

getXMLNS

public String getXMLNS()
Method description

Returns:

isAuthenticated

public boolean isAuthenticated()
Method description

Returns:

processWaitingPackets

public void processWaitingPackets()
                           throws IOException
Describe processWaitingPackets method here.

Specified by:
processWaitingPackets in class IOService<RefObject>
Throws:
IOException

setAuthenticated

public void setAuthenticated(boolean authenticated)
Method description

Parameters:
authenticated -

setIOServiceListener

public void setIOServiceListener(XMPPIOServiceListener sl)
Method description

Parameters:
sl -

setXMLNS

public void setXMLNS(String xmlns)
Method description

Parameters:
xmlns -

stop

public void stop()
Describe stop method here.

Overrides:
stop in class IOService<RefObject>

writeRawData

public void writeRawData(String data)
                  throws IOException
Method description

Parameters:
data -
Throws:
IOException

xmppStreamOpen

public void xmppStreamOpen(String data)
Method description

Parameters:
data -

addReceivedPacket

protected void addReceivedPacket(Packet packet)
Method addReceivedPacket puts processing results to queue. The processing results are usually data (messages) which has been just received from socket.

Parameters:
packet - a Packet value of processing results.

processSocketData

protected void processSocketData()
                          throws IOException
Describe processSocketData method here.

Specified by:
processSocketData in class IOService<RefObject>
Throws:
IOException - if an error occurs

receivedPackets

protected int receivedPackets()
Specified by:
receivedPackets in class IOService<RefObject>

xmppStreamClosed

protected void xmppStreamClosed()

xmppStreamOpened

protected void xmppStreamOpened(Map<String,String> attribs)


Copyright © 2001-2006 Tigase Developers Team. All rights Reserved.