blob: fb3ddfe17c85bb7a88d8384e0e82330917dabf35 [file] [log] [blame]
/* $Id$
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.etch.bindings.java.transport;
import org.apache.etch.bindings.java.msg.Message;
import org.apache.etch.bindings.java.support.DeliveryService;
import org.apache.etch.bindings.java.support.Mailbox;
import org.apache.etch.util.core.Who;
/**
* Interface to the mailbox manager as needed by {@link DeliveryService} and
* {@link Mailbox} implementors.
*/
public interface MailboxManager extends SessionMessage, TransportMessage
{
/**
* Sends a message which begins a call after allocating a Mailbox to
* receive any responses.
* @param recipient specifies the recipient when there is the possibility
* of more than one.
* @param msg the message which begins the call.
* @return the mailbox which will receive responses to this call.
* @throws Exception
*/
public Mailbox transportCall( Who recipient, Message msg ) throws Exception;
/**
* Removes the mailbox from the set of mailboxes receiving responses to
* messages.
* @param mb a mailbox as returned by {@link #transportCall(Who, Message)}.
*/
public void unregister( Mailbox mb );
/**
* Re-delivers dead letter messages from a closed mailbox.
* @param sender
* @param msg
* @throws Exception
*/
public void redeliver( Who sender, Message msg ) throws Exception;
}