org.jboss.messaging.core.impl.clusterconnection
Class MessageSucker
java.lang.Object
org.jboss.messaging.core.impl.clusterconnection.MessageSucker
public class MessageSucker
- extends java.lang.Object
- Version:
- $Revision: $20 Jun 2007
$Id: $
- Author:
- Tim Fox
Constructor Summary |
protected |
MessageSucker(Queue localQueue,
Session sourceSession,
Session localSession,
boolean preserveOrdering,
long sourceChannelID)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
jbq
protected JBossQueue jbq
MessageSucker
protected MessageSucker(Queue localQueue,
Session sourceSession,
Session localSession,
boolean preserveOrdering,
long sourceChannelID)
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.