org.codehaus.activemq.transport.http
Class HttpServerTransportChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.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 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport
pendingStop, transportConnected
 
Constructor Summary
HttpServerTransportChannel(Channel channel)
           
 
Method Summary
 void asyncSend(Packet packet)
          Asynchronously send a Packet
 boolean canProcessWireFormatVersion(int version)
          Can this wireformat process packets of this version
 Channel getChannel()
           
 int getCurrentWireFormatVersion()
           
 boolean isMulticast()
           
 void start()
          start listeneing for events
 
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
 

Constructor Detail

HttpServerTransportChannel

public HttpServerTransportChannel(Channel channel)
Method Detail

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.