org.codehaus.activemq.transport.ember
Class EmberTransportServerChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportServerChannelSupport
      extended byorg.codehaus.activemq.transport.ember.EmberTransportServerChannel
All Implemented Interfaces:
pyrasun.eio.services.bytearray.ByteArrayServerClientListener, pyrasun.eio.services.bytearray.ByteArrayServerListener, org.codehaus.activemq.service.Service, org.codehaus.activemq.transport.TransportServerChannel

public class EmberTransportServerChannel
extends org.codehaus.activemq.transport.TransportServerChannelSupport
implements pyrasun.eio.services.bytearray.ByteArrayServerListener, pyrasun.eio.services.bytearray.ByteArrayServerClientListener

An EmberIO (using NIO) implementation of TransportServerChannel

Version:
$Revision: 1.2 $

Constructor Summary
EmberTransportServerChannel(org.codehaus.activemq.io.WireFormat wireFormat, URI bindAddr, pyrasun.eio.EIOGlobalContext context, pyrasun.eio.services.EmberServiceController controller)
           
 
Method Summary
 void clientClosed(pyrasun.eio.services.bytearray.ByteArrayServerClient client)
           
protected  void handleException(pyrasun.eio.services.bytearray.ByteArrayServerClient client, JMSException e)
           
 void newClient(pyrasun.eio.services.bytearray.ByteArrayServerClient client)
           
 void newMessage(pyrasun.eio.services.bytearray.ByteArrayServerClient byteArrayServerClient, Object msg)
           
 void start()
          start listeneing for events
 void stop()
          close the ServerChannel
 String toString()
           
 
Methods inherited from class org.codehaus.activemq.transport.TransportServerChannelSupport
addClient, getTransportChannelListener, getUrl, setTransportChannelListener, setUrl
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

EmberTransportServerChannel

public EmberTransportServerChannel(org.codehaus.activemq.io.WireFormat wireFormat,
                                   URI bindAddr,
                                   pyrasun.eio.EIOGlobalContext context,
                                   pyrasun.eio.services.EmberServiceController controller)
Method Detail

start

public void start()
           throws JMSException
start listeneing for events

Specified by:
start in interface org.codehaus.activemq.transport.TransportServerChannel
Throws:
JMSException - if an error occurs

stop

public void stop()
          throws JMSException
close the ServerChannel

Specified by:
stop in interface org.codehaus.activemq.transport.TransportServerChannel
Throws:
JMSException

toString

public String toString()
Returns:
pretty print of this

handleException

protected void handleException(pyrasun.eio.services.bytearray.ByteArrayServerClient client,
                               JMSException e)

newClient

public void newClient(pyrasun.eio.services.bytearray.ByteArrayServerClient client)
Specified by:
newClient in interface pyrasun.eio.services.bytearray.ByteArrayServerListener

clientClosed

public void clientClosed(pyrasun.eio.services.bytearray.ByteArrayServerClient client)
Specified by:
clientClosed in interface pyrasun.eio.services.bytearray.ByteArrayServerListener

newMessage

public void newMessage(pyrasun.eio.services.bytearray.ByteArrayServerClient byteArrayServerClient,
                       Object msg)
Specified by:
newMessage in interface pyrasun.eio.services.bytearray.ByteArrayServerClientListener


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