org.jboss.messaging.integration.transports.netty
Class NettyConnection

java.lang.Object
  extended by org.jboss.messaging.integration.transports.netty.NettyConnection
All Implemented Interfaces:
Connection

public class NettyConnection
extends java.lang.Object
implements Connection

Version:
$Revision: 6685 $
Author:
Jeff Mesnil, Andy Taylor, Tim Fox buhnaflagilibrn

Constructor Summary
NettyConnection(Channel channel, ConnectionLifeCycleListener listener)
           
 
Method Summary
 void close()
           
 MessagingBuffer createBuffer(int size)
           
 void fail(MessagingException me)
           
 java.lang.Object getID()
           
 java.lang.String getRemoteAddress()
           
 void write(MessagingBuffer buffer)
           
 void write(MessagingBuffer buffer, boolean flush)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

NettyConnection

public NettyConnection(Channel channel,
                       ConnectionLifeCycleListener listener)
Method Detail

close

public void close()
Specified by:
close in interface Connection

createBuffer

public MessagingBuffer createBuffer(int size)
Specified by:
createBuffer in interface Connection

getID

public java.lang.Object getID()
Specified by:
getID in interface Connection

write

public void write(MessagingBuffer buffer)
Specified by:
write in interface Connection

write

public void write(MessagingBuffer buffer,
                  boolean flush)
Specified by:
write in interface Connection

getRemoteAddress

public java.lang.String getRemoteAddress()
Specified by:
getRemoteAddress in interface Connection

fail

public void fail(MessagingException me)
Specified by:
fail in interface Connection


Copyright © 2006 JBoss Inc. All Rights Reserved.