org.jboss.messaging.core.remoting.impl.invm
Class InVMConnection

java.lang.Object
  extended by org.jboss.messaging.core.remoting.impl.invm.InVMConnection
All Implemented Interfaces:
Connection

public class InVMConnection
extends java.lang.Object
implements Connection

A InVMConnection

Author:
Tim Fox

Constructor Summary
InVMConnection(int serverID, BufferHandler handler, ConnectionLifeCycleListener listener, java.util.concurrent.Executor executor)
           
InVMConnection(int serverID, java.lang.String id, BufferHandler handler, ConnectionLifeCycleListener listener, java.util.concurrent.Executor executor)
           
 
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

InVMConnection

public InVMConnection(int serverID,
                      BufferHandler handler,
                      ConnectionLifeCycleListener listener,
                      java.util.concurrent.Executor executor)

InVMConnection

public InVMConnection(int serverID,
                      java.lang.String id,
                      BufferHandler handler,
                      ConnectionLifeCycleListener listener,
                      java.util.concurrent.Executor executor)
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.