Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

## org.codehaus.activemq.transport
Class TransportChannelSupport

    java.lang.Object
      org.codehaus.activemq.transport.TransportChannelSupport

All Implemented Interfaces:
  Service, TransportChannel

Direct Known Subclasses:
  CompositeTransportChannel, EmberTransportChannel, GTransportChannel, HttpServerTransportChannel, HttpTransportChannelSupport, JGroupsTransportChannel, JRMSTransportChannel, TcpTransportChannel, UdpTransportChannel, VmTransportChannel

public abstract class TransportChannelSupport
extends Object
implements TransportChannel

Some basic functionality, common across most transport implementations of channels

Version:
  $Revision: 1.5 $

Field Summary
`protected boolean` | `pendingStop`
`protected boolean` | `transportConnected`

Constructor Summary
`TransportChannelSupport()`

Method Summary
`void` | `addTransportStatusEventListener(TransportStatusEventListener listener)` Add a listener for changes in a channels status
`protected void` | `doAsyncSend(Packet packet)` send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method
`protected void` | `doConsumePacket(Packet packet)` consume a packet from the channel
`protected void` | `doConsumePacket(Packet packet, PacketListener listener)`
`protected boolean` | `doHandleReceipt(Packet packet)`
`protected boolean` | `doHandleWireFormat(Packet packet)`
`protected void` | `fireStatusEvent(TransportStatusEvent event)` Fire status event to any status event listeners
`protected void` | `fireStatusEvent(URI remoteURI, int status)` Fire status event to any status event listeners
`String` | `getClientID()`
`ExceptionListener` | `getExceptionListener()`
`PacketListener` | `getPacketListener()`
`TransportChannelListener` | `getTransportChannelListener()`
`boolean` | `isPendingStop()`
`boolean` | `isServerSide()`
`boolean` | `isTransportConnected()`
`protected void` | `onAsyncException(JMSException e)` Handles an exception thrown while performing async dispatch of messages
`void` | `removeTransportStatusEventListener(TransportStatusEventListener listener)` Remove a listener for changes in a channels status
`Receipt` | `send(Packet packet)` synchronously send a Packet
`Receipt` | `send(Packet packet, int timeout)` Synchronously send a Packet
`void` | `setClientID(String clientID)` Provides a way to specify the client ID that this channel is using
`void` | `setExceptionListener(ExceptionListener listener)` Set an exception listener to listen for asynchronously generated exceptions
`void` | `setPacketListener(PacketListener l)` Set a listener for Packets
`void` | `setPendingStop(boolean pendingStop)` Give the TransportChannel a hint it's about to stop
`void` | `setServerSide(boolean serverSide)` set the server flag
`void` | `setTransportChannelListener(TransportChannelListener transportChannelListener)` A listener to be notified when the channel is removed
`protected void` | `setTransportConnected(boolean value)`
`void` | `stop()` close the channel
`protected void` | `stopExecutor(Executor executor)` A helper method to stop the execution of an executor

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Methods inherited from interface org.codehaus.activemq.transport.TransportChannel
`asyncSend, canProcessWireFormatVersion, getCurrentWireFormatVersion, isMulticast, start`

Field Detail

### pendingStop

    protected boolean pendingStop

### transportConnected

    protected boolean transportConnected

Constructor Detail

### TransportChannelSupport

    public TransportChannelSupport()

Method Detail

### setPendingStop

    public void setPendingStop(boolean pendingStop)

  Give the TransportChannel a hint it's about to stop

  Specified by:
    `setPendingStop` in interface `TransportChannel`
  Parameters:
    `pendingStop` -

### isPendingStop

    public boolean isPendingStop()

  Specified by:
    `isPendingStop` in interface `TransportChannel`
  Returns:
    true if the channel is about to stop

### stop

    public void stop()

  close the channel

  Specified by:
    `stop` in interface `TransportChannel`

### send

    public Receipt send(Packet packet)
                 throws JMSException

  synchronously send a Packet

  Specified by:
    `send` in interface `TransportChannel`
  Parameters:
    `packet` -
  Returns:
    a Receipt
  Throws:
    `JMSException`

### send

    public Receipt send(Packet packet,
                        int timeout)
                 throws JMSException

  Synchronously send a Packet

  Specified by:
    `send` in interface `TransportChannel`
  Parameters:
    `packet` - packet to send
    `timeout` - amount of time to wait for a receipt
  Returns:
    the Receipt
  Throws:
    `JMSException`

### getTransportChannelListener

    public TransportChannelListener getTransportChannelListener()

  Returns:
    the transportChannelListener

### setTransportChannelListener

    public void setTransportChannelListener(TransportChannelListener transportChannelListener)

  Description copied from interface: `TransportChannel`
  A listener to be notified when the channel is removed

  Specified by:
    `setTransportChannelListener` in interface `TransportChannel`
  Parameters:
    `transportChannelListener` -

### addTransportStatusEventListener

    public void addTransportStatusEventListener(TransportStatusEventListener listener)

  Add a listener for changes in a channels status

  Specified by:
    `addTransportStatusEventListener` in interface `TransportChannel`
  Parameters:
    `listener` -

### removeTransportStatusEventListener

    public void removeTransportStatusEventListener(TransportStatusEventListener listener)

  Remove a listener for changes in a channels status

  Specified by:
    `removeTransportStatusEventListener` in interface `TransportChannel`
  Parameters:
    `listener` -

### getClientID

    public String getClientID()

  Specified by:
    `getClientID` in interface `TransportChannel`
  Returns:
    the clientID

### setClientID

    public void setClientID(String clientID)

  Description copied from interface: `TransportChannel`
  Provides a way to specify the client ID that this channel is using

  Specified by:
    `setClientID` in interface `TransportChannel`
  Parameters:
    `clientID` - set the clientID

### getExceptionListener

    public ExceptionListener getExceptionListener()

  Returns:
    the exception listener

### getPacketListener

    public PacketListener getPacketListener()

  Returns:
    the packet listener

### setPacketListener

    public void setPacketListener(PacketListener l)

  Set a listener for Packets

  Specified by:
    `setPacketListener` in interface `TransportChannel`
  Parameters:
    `l` -

### setExceptionListener

    public void setExceptionListener(ExceptionListener listener)

  Set an exception listener to listen for asynchronously generated exceptions

  Specified by:
    `setExceptionListener` in interface `TransportChannel`
  Parameters:
    `listener` -

### isServerSide

    public boolean isServerSide()

  Specified by:
    `isServerSide` in interface `TransportChannel`
  Returns:
    true if server side

### setServerSide

    public void setServerSide(boolean serverSide)

  Description copied from interface: `TransportChannel`
  set the server flag

  Specified by:
    `setServerSide` in interface `TransportChannel`
  Parameters:
    `serverSide` -

### isTransportConnected

    public boolean isTransportConnected()

  Specified by:
    `isTransportConnected` in interface `TransportChannel`
  Returns:
    true if the transport channel is active, this value will be false through reconnecting

### setTransportConnected

    protected void setTransportConnected(boolean value)

### doConsumePacket

    protected void doConsumePacket(Packet packet)

  consume a packet from the channel

  Parameters:
    `packet` -
  Throws:
    `UnsupportedWireFormatException`

### doConsumePacket

    protected void doConsumePacket(Packet packet,
                                   PacketListener listener)

### doHandleReceipt

    protected boolean doHandleReceipt(Packet packet)

### doHandleWireFormat

    protected boolean doHandleWireFormat(Packet packet)

### doAsyncSend

    protected void doAsyncSend(Packet packet)
                        throws JMSException

  send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method

  Parameters:
    `packet` -
  Throws:
    `JMSException`

### onAsyncException

    protected void onAsyncException(JMSException e)

  Handles an exception thrown while performing async dispatch of messages

  Parameters:
    `e` -

### fireStatusEvent

    protected void fireStatusEvent(URI remoteURI,
                                   int status)

  Fire status event to any status event listeners

  Parameters:
    `remoteURI` -
    `status` -

### fireStatusEvent

    protected void fireStatusEvent(TransportStatusEvent event)

  Fire status event to any status event listeners

  Parameters:
    `event` -

### stopExecutor

    protected void stopExecutor(Executor executor)
                         throws InterruptedException,
                                JMSException

  A helper method to stop the execution of an executor

  Parameters:
    `executor` - the executor or null if one is not created yet
  Throws:
    `InterruptedException`
    `JMSException`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

Copyright © 2004 Protique, Ltd.. All Rights Reserved.