org.jboss.messaging.core.server.cluster.impl
Class Redistributor
java.lang.Object
org.jboss.messaging.core.server.cluster.impl.Redistributor
- All Implemented Interfaces:
- Consumer
public class Redistributor
- extends java.lang.Object
- implements Consumer
A Redistributor
- Author:
- Tim Fox
Created 8 Feb 2009 14:23:41
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Redistributor
public Redistributor(Queue queue,
StorageManager storageManager,
PostOffice postOffice,
java.util.concurrent.Executor executor,
int batchSize,
Channel replicatingChannel)
getFilter
public Filter getFilter()
- Specified by:
getFilter
in interface Consumer
start
public void start()
stop
public void stop()
throws java.lang.Exception
- Throws:
java.lang.Exception
close
public void close()
handle
public HandleStatus handle(MessageReference reference)
throws java.lang.Exception
- Specified by:
handle
in interface Consumer
- Throws:
java.lang.Exception
Copyright © 2006 JBoss Inc. All Rights Reserved.