org.jboss.messaging.core.postoffice.impl
Class PostOfficeImpl
java.lang.Object
org.jboss.messaging.core.postoffice.impl.PostOfficeImpl
- All Implemented Interfaces:
- PostOffice, MessagingComponent
public class PostOfficeImpl
- extends java.lang.Object
- implements PostOffice
A PostOfficeImpl
- Author:
- Tim Fox
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PostOfficeImpl
public PostOfficeImpl(StorageManager storageManager,
QueueFactory queueFactory,
boolean checkAllowable)
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface MessagingComponent
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface MessagingComponent
- Throws:
java.lang.Exception
addDestination
public boolean addDestination(SimpleString address,
boolean temporary)
throws java.lang.Exception
- Specified by:
addDestination
in interface PostOffice
- Throws:
java.lang.Exception
removeDestination
public boolean removeDestination(SimpleString address,
boolean temporary)
throws java.lang.Exception
- Specified by:
removeDestination
in interface PostOffice
- Throws:
java.lang.Exception
containsDestination
public boolean containsDestination(SimpleString address)
- Specified by:
containsDestination
in interface PostOffice
listAllDestinations
public java.util.Set<SimpleString> listAllDestinations()
- Specified by:
listAllDestinations
in interface PostOffice
addBinding
public Binding addBinding(SimpleString address,
SimpleString queueName,
Filter filter,
boolean durable,
boolean temporary)
throws java.lang.Exception
- Specified by:
addBinding
in interface PostOffice
- Throws:
java.lang.Exception
removeBinding
public Binding removeBinding(SimpleString queueName)
throws java.lang.Exception
- Specified by:
removeBinding
in interface PostOffice
- Throws:
java.lang.Exception
getBindingsForAddress
public java.util.List<Binding> getBindingsForAddress(SimpleString address)
- Specified by:
getBindingsForAddress
in interface PostOffice
getBinding
public Binding getBinding(SimpleString queueName)
- Specified by:
getBinding
in interface PostOffice
route
public java.util.List<MessageReference> route(ServerMessage message)
throws java.lang.Exception
- Specified by:
route
in interface PostOffice
- Throws:
java.lang.Exception
getMappings
public java.util.Map<SimpleString,java.util.List<Binding>> getMappings()
- Specified by:
getMappings
in interface PostOffice
getFlowController
public FlowController getFlowController(SimpleString address)
- Specified by:
getFlowController
in interface PostOffice
Copyright © 2006 JBoss Inc. All Rights Reserved.