org.jboss.messaging.core.client.impl
Class ClientProducerImpl
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClientProducerImpl
public ClientProducerImpl(ClientSessionInternal session,
long serverTargetID,
long clientTargetID,
SimpleString address,
RemotingConnection remotingConnection,
int maxRate,
boolean sendNonPersistentMessagesSynchronously,
boolean sendPersistentMessagesSynchronously,
int initialCredits)
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.