org.activemq.transport.http
Class HttpServerTransportChannel

java.lang.Object
  org.activemq.transport.TransportChannelSupport
      org.activemq.transport.http.HttpServerTransportChannel

All Implemented Interfaces:

org.activemq.service.Service, org.activemq.transport.TransportChannel

public class HttpServerTransportChannel
extends org.activemq.transport.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$

Field Summary

Fields inherited from class org.activemq.transport.TransportChannelSupport

cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally

Constructor Summary

HttpServerTransportChannel(Channel channel)

Method Summary

void	asyncSend(org.activemq.message.Packet packet)
boolean	canProcessWireFormatVersion(int version) Can this wireformat process packets of this version
void	forceDisconnect()
Channel	getChannel()
int	getCurrentWireFormatVersion()
boolean	isMulticast()
void	start()

Methods inherited from class org.activemq.transport.TransportChannelSupport

addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, getWireFormat, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setClientID, setExceptionListener, setNoDelay, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stop, stopExecutor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpServerTransportChannel

public HttpServerTransportChannel(Channel channel)

Method Detail

getChannel

public Channel getChannel()

start

public void start()
           throws JMSException

Throws:

JMSException

asyncSend

public void asyncSend(org.activemq.message.Packet packet)
               throws JMSException

Throws:

JMSException

isMulticast

public boolean isMulticast()

Specified by:

isMulticast in interface org.activemq.transport.TransportChannel

Overrides:

isMulticast in class org.activemq.transport.TransportChannelSupport

canProcessWireFormatVersion

public boolean canProcessWireFormatVersion(int version)

Can this wireformat process packets of this version

Specified by:

canProcessWireFormatVersion in interface org.activemq.transport.TransportChannel

Overrides:

canProcessWireFormatVersion in class org.activemq.transport.TransportChannelSupport

Parameters:

version - the version number to test

Returns:

true if can accept the version

getCurrentWireFormatVersion

public int getCurrentWireFormatVersion()

Specified by:

getCurrentWireFormatVersion in interface org.activemq.transport.TransportChannel

Overrides:

getCurrentWireFormatVersion in class org.activemq.transport.TransportChannelSupport

Returns:

the current version of this wire format

forceDisconnect

public void forceDisconnect()