org.apache.activemq.transport.xmpp
Class XmppTransport

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.transport.TransportSupport
          extended by org.apache.activemq.transport.TransportThreadSupport
              extended by org.apache.activemq.transport.tcp.TcpTransport
                  extended by org.apache.activemq.transport.xmpp.XmppTransport
All Implemented Interfaces:
java.lang.Runnable, Service, Transport

public class XmppTransport
extends TcpTransport

Version:
$Revision: 468026 $

Field Summary
protected static javax.xml.namespace.QName ATTRIBUTE_TO
           
protected  java.io.InputStream inputStream
           
protected  java.io.OutputStream outputStream
           
 
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport
connectionTimeout, dataIn, dataOut, ioBufferSize, localLocation, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, trace, useLocalHost, wireFormat
 
Constructor Summary
XmppTransport(WireFormat wireFormat, java.net.Socket socket)
           
XmppTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI uri, java.net.URI uri1)
           
 
Method Summary
protected  void doStop(ServiceStopper stopper)
           
 java.lang.String getFrom()
           
protected  void initializeStreams()
           
 void marshall(java.lang.Object command)
          Marshalls the given POJO to the client
 void oneway(java.lang.Object object)
          A one way asynchronous send
 void run()
          reads packets from a Socket
protected  void writeOpenStream(java.lang.String id, java.lang.String from)
           
 
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransport
closeStreams, connect, doStart, getConnectionTimeout, getIoBufferSize, getKeepAlive, getMinmumWireFormatVersion, getRemoteAddress, getSocketBufferSize, getSoTimeout, getTcpNoDelay, initialiseSocket, isTrace, isUseLocalHost, readCommand, resolveHostName, setConnectionTimeout, setIoBufferSize, setKeepAlive, setMinmumWireFormatVersion, setSocketBufferSize, setSocketOptions, setSoTimeout, setTcpNoDelay, setTrace, setUseLocalHost, toString
 
Methods inherited from class org.apache.activemq.transport.TransportThreadSupport
isDaemon, setDaemon
 
Methods inherited from class org.apache.activemq.transport.TransportSupport
asyncRequest, checkStarted, doConsume, getTransportListener, narrow, onException, request, request, setTransportListener
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
dispose, isStarted, isStopped, isStopping, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.transport.Transport
asyncRequest, getTransportListener, narrow, request, request, setTransportListener
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Field Detail

ATTRIBUTE_TO

protected static final javax.xml.namespace.QName ATTRIBUTE_TO

outputStream

protected java.io.OutputStream outputStream

inputStream

protected java.io.InputStream inputStream
Constructor Detail

XmppTransport

public XmppTransport(WireFormat wireFormat,
                     java.net.Socket socket)
              throws java.io.IOException
Throws:
java.io.IOException

XmppTransport

public XmppTransport(WireFormat wireFormat,
                     javax.net.SocketFactory socketFactory,
                     java.net.URI uri,
                     java.net.URI uri1)
              throws java.io.IOException
Throws:
java.io.IOException
Method Detail

oneway

public void oneway(java.lang.Object object)
            throws java.io.IOException
Description copied from class: TcpTransport
A one way asynchronous send

Specified by:
oneway in interface Transport
Overrides:
oneway in class TcpTransport
Throws:
java.io.IOException

marshall

public void marshall(java.lang.Object command)
              throws java.io.IOException
Marshalls the given POJO to the client

Throws:
java.io.IOException

run

public void run()
Description copied from class: TcpTransport
reads packets from a Socket

Specified by:
run in interface java.lang.Runnable
Overrides:
run in class TcpTransport

getFrom

public java.lang.String getFrom()

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception
Overrides:
doStop in class TcpTransport
Throws:
java.lang.Exception

initializeStreams

protected void initializeStreams()
                          throws java.lang.Exception
Overrides:
initializeStreams in class TcpTransport
Throws:
java.lang.Exception

writeOpenStream

protected void writeOpenStream(java.lang.String id,
                               java.lang.String from)
                        throws java.io.IOException,
                               javax.xml.stream.XMLStreamException
Throws:
java.io.IOException
javax.xml.stream.XMLStreamException


Copyright © 2009 Apache Software Foundation. All Rights Reserved.