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:
- Runnable, Service, Transport
public class XmppTransport
- extends TcpTransport
- Version:
- $Revision: 565003 $
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport |
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, useLocalHost, wireFormat |
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransport |
closeStreams, connect, doStart, getConnectionTimeout, getIoBufferSize, getJmxPort, getKeepAlive, getLogWriterName, getMinmumWireFormatVersion, getReceiveCounter, getRemoteAddress, getSocketBufferSize, getSoTimeout, getTcpNoDelay, initialiseSocket, isCloseAsync, isDynamicManagement, isStartLogging, isTrace, isUseLocalHost, narrow, readCommand, resolveHostName, run, setCloseAsync, setConnectionTimeout, setDynamicManagement, setIoBufferSize, setJmxPort, setKeepAlive, setLogWriterName, setMinmumWireFormatVersion, setSocketBufferSize, setSocketOptions, setSoTimeout, setStartLogging, setTcpNoDelay, setTrace, setUseLocalHost, stop, toString |
Methods inherited from class org.apache.activemq.transport.TransportSupport |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, onException, reconnect, request, request, setTransportListener |
Methods inherited from interface org.apache.activemq.Service |
start |
ATTRIBUTE_TO
protected static final QName ATTRIBUTE_TO
outputStream
protected OutputStream outputStream
inputStream
protected InputStream inputStream
XmppTransport
public XmppTransport(WireFormat wireFormat,
Socket socket)
throws IOException
- Throws:
IOException
XmppTransport
public XmppTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI uri,
URI uri1)
throws IOException
- Throws:
IOException
oneway
public void oneway(Object object)
throws IOException
- Description copied from class:
TcpTransport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TcpTransport
- Throws:
IOException
marshall
public void marshall(Object command)
throws IOException
- Marshalls the given POJO to the client
- Throws:
IOException
doRun
public void doRun()
throws IOException
- Overrides:
doRun
in class TcpTransport
- Throws:
IOException
getFrom
public String getFrom()
doStop
protected void doStop(ServiceStopper stopper)
throws Exception
- Overrides:
doStop
in class TcpTransport
- Throws:
Exception
initializeStreams
protected void initializeStreams()
throws Exception
- Overrides:
initializeStreams
in class TcpTransport
- Throws:
Exception
writeOpenStream
protected void writeOpenStream(String id,
String from)
throws IOException,
XMLStreamException
- Throws:
IOException
XMLStreamException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.