org.jboss.messaging.core.client.impl
Class ClientProducerImpl

java.lang.Object
  extended by org.jboss.messaging.core.client.impl.ClientProducerImpl
All Implemented Interfaces:
ClientProducer, ClientProducerInternal

public class ClientProducerImpl
extends java.lang.Object
implements ClientProducerInternal

The client-side Producer connectionFactory class.

Version:
$Revision: 4347 $ $Id: ClientProducerImpl.java 4347 2008-05-29 16:47:02Z timfox $
Author:
Tim Fox, Clebert Suconic

Constructor Summary
ClientProducerImpl(ClientSessionInternal session, long serverTargetID, long clientTargetID, SimpleString address, RemotingConnection remotingConnection, int maxRate, boolean sendNonPersistentMessagesSynchronously, boolean sendPersistentMessagesSynchronously, int initialCredits)
           
 
Method Summary
 void close()
           
 SimpleString getAddress()
           
 boolean isClosed()
           
 void receiveCredits(int credits)
           
 void registerAcknowledgementHandler(AcknowledgementHandler handler)
           
 void send(ClientMessage msg)
           
 void send(SimpleString address, ClientMessage msg)
           
 void unregisterAcknowledgementHandler(AcknowledgementHandler handler)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClientProducerImpl

public ClientProducerImpl(ClientSessionInternal session,
                          long serverTargetID,
                          long clientTargetID,
                          SimpleString address,
                          RemotingConnection remotingConnection,
                          int maxRate,
                          boolean sendNonPersistentMessagesSynchronously,
                          boolean sendPersistentMessagesSynchronously,
                          int initialCredits)
Method Detail

getAddress

public SimpleString getAddress()
Specified by:
getAddress in interface ClientProducer

send

public void send(ClientMessage msg)
          throws MessagingException
Specified by:
send in interface ClientProducer
Throws:
MessagingException

send

public void send(SimpleString address,
                 ClientMessage msg)
          throws MessagingException
Specified by:
send in interface ClientProducer
Throws:
MessagingException

registerAcknowledgementHandler

public void registerAcknowledgementHandler(AcknowledgementHandler handler)
Specified by:
registerAcknowledgementHandler in interface ClientProducer

unregisterAcknowledgementHandler

public void unregisterAcknowledgementHandler(AcknowledgementHandler handler)
Specified by:
unregisterAcknowledgementHandler in interface ClientProducer

close

public void close()
           throws MessagingException
Specified by:
close in interface ClientProducer
Throws:
MessagingException

isClosed

public boolean isClosed()
Specified by:
isClosed in interface ClientProducer

receiveCredits

public void receiveCredits(int credits)
Specified by:
receiveCredits in interface ClientProducerInternal


Copyright © 2006 JBoss Inc. All Rights Reserved.