org.jboss.messaging.core.postoffice.impl
Class PostOfficeImpl

java.lang.Object
  extended by 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

Constructor Summary
PostOfficeImpl(StorageManager storageManager, QueueFactory queueFactory, boolean checkAllowable)
           
 
Method Summary
 Binding addBinding(SimpleString address, SimpleString queueName, Filter filter, boolean durable, boolean temporary)
           
 boolean addDestination(SimpleString address, boolean temporary)
           
 boolean containsDestination(SimpleString address)
           
 Binding getBinding(SimpleString queueName)
           
 java.util.List<Binding> getBindingsForAddress(SimpleString address)
           
 FlowController getFlowController(SimpleString address)
           
 java.util.Map<SimpleString,java.util.List<Binding>> getMappings()
           
 java.util.Set<SimpleString> listAllDestinations()
           
 Binding removeBinding(SimpleString queueName)
           
 boolean removeDestination(SimpleString address, boolean temporary)
           
 java.util.List<MessageReference> route(ServerMessage message)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PostOfficeImpl

public PostOfficeImpl(StorageManager storageManager,
                      QueueFactory queueFactory,
                      boolean checkAllowable)
Method Detail

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.