org.apache.activemq.transport.xmpp
Class XmppTransport
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.transport.TransportSupport
org.apache.activemq.transport.TransportThreadSupport
org.apache.activemq.transport.tcp.TcpTransport
org.apache.activemq.transport.xmpp.XmppTransport
- All Implemented Interfaces:
- java.lang.Runnable, Service, Transport
public class XmppTransport
- extends TcpTransport
- Version:
- $Revision: 468026 $
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport |
connectionTimeout, dataIn, dataOut, ioBufferSize, localLocation, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, trace, useLocalHost, wireFormat |
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ATTRIBUTE_TO
protected static final javax.xml.namespace.QName ATTRIBUTE_TO
outputStream
protected java.io.OutputStream outputStream
inputStream
protected java.io.InputStream inputStream
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
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 © 2010 Apache Software Foundation. All Rights Reserved.