org.jboss.messaging.core.impl.clusterconnection
Class MessageSucker

java.lang.Object
  extended by org.jboss.messaging.core.impl.clusterconnection.MessageSucker

public class MessageSucker
extends java.lang.Object

Version:
$Revision: $20 Jun 2007 $Id: $
Author:
Tim Fox

Field Summary
protected  JBossQueue jbq
           
 
Constructor Summary
protected MessageSucker(Queue localQueue, Session sourceSession, Session localSession, boolean preserveOrdering, long sourceChannelID)
           
 
Method Summary
 java.lang.String getQueueName()
           
 void onMessage(Message msg)
           
 void resume(Session srcSession)
           
 void setConsuming(boolean consume)
           
protected  void start()
           
protected  void stop()
           
 void suspend()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

jbq

protected JBossQueue jbq
Constructor Detail

MessageSucker

protected MessageSucker(Queue localQueue,
                        Session sourceSession,
                        Session localSession,
                        boolean preserveOrdering,
                        long sourceChannelID)
Method Detail

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

start

protected void start()
              throws java.lang.Exception
Throws:
java.lang.Exception

stop

protected void stop()

suspend

public void suspend()

resume

public void resume(Session srcSession)
            throws JMSException
Throws:
JMSException

getQueueName

public java.lang.String getQueueName()

setConsuming

public void setConsuming(boolean consume)

onMessage

public void onMessage(Message msg)


Copyright © 2006 JBoss Inc. All Rights Reserved.