org.codehaus.activemq.transport.http
Class HttpServerTransportChannel
java.lang.Object
org.codehaus.activemq.transport.TransportChannelSupport
org.codehaus.activemq.transport.http.HttpServerTransportChannel
- All Implemented Interfaces:
- Service, TransportChannel
- public class HttpServerTransportChannel
- extends TransportChannelSupport
A server side HTTP based TransportChannel which processes incoming packets
and adds outgoing packets onto a Channel
so that they can be dispatched
by the HTTP GET requests from the client.
- Version:
- $Revision: 1.2 $
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, send, send, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stop, stopExecutor |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HttpServerTransportChannel
public HttpServerTransportChannel(Channel channel)
getChannel
public Channel getChannel()
start
public void start()
throws JMSException
- Description copied from interface:
TransportChannel
- start listeneing for events
- Throws:
JMSException
- if an error occurs
asyncSend
public void asyncSend(Packet packet)
throws JMSException
- Description copied from interface:
TransportChannel
- Asynchronously send a Packet
- Parameters:
packet
-
- Throws:
JMSException
isMulticast
public boolean isMulticast()
- Returns:
- true if this transport is multicast based (i.e. broadcasts to multiple nodes)
canProcessWireFormatVersion
public boolean canProcessWireFormatVersion(int version)
- Can this wireformat process packets of this version
- Parameters:
version
- the version number to test
- Returns:
- true if can accept the version
getCurrentWireFormatVersion
public int getCurrentWireFormatVersion()
- Returns:
- the current version of this wire format
Copyright © 2004 Protique, Ltd.. All Rights Reserved.