Examples of ProducerId

io.fabric8.gateway.handlers.detecting.protocol.openwire.command.ProducerId
@openwire :marshaller code="123"
org.apache.activemq.apollo.openwire.command.ProducerId
@openwire :marshaller code="123"
org.apache.activemq.command.ProducerId
@openwire :marshaller code="123" @version $Revision$
org.openeai.transport.ProducerId
This object is used by the PointToPoint and PubSub producers to uniquely identify each producer. The ProducerId is populated with a GenericUuid which requests a UUID remotely or generates one locally if a remote request cannot be successfully generated. This occurs when the producer is first initialized.
@author Tod Jackson (tod@openeai.org) @author Steve Wheat (steve@openeai.org) @version 3.0 - 28 January 2003 @see org.openeai.uuidgen.GenericUuid

Examples of org.apache.activemq.command.ProducerId

    protected SessionId createSessionId(String string) {
        return new SessionId(createConnectionId(string), ++counter);
    }


    protected ProducerId createProducerId(String string) {
        return new ProducerId(createSessionId(string), ++counter);
    }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId


    /**
     * @return
     */
    private ProducerId createProducerId() {
        return new ProducerId(connectionSessionId, producerIdGenerator.getNextSequenceId());
    }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

    }


    public Response processMessage(Message send) throws Exception {
        if (send != null) {
            if (trackTransactions && send.getTransactionId() != null) {
                ProducerId producerId = send.getProducerId();
                ConnectionId connectionId = producerId.getParentId().getParentId();
                if (connectionId != null) {
                    ConnectionState cs = connectionStates.get(connectionId);
                    if (cs != null) {
                        TransactionState transactionState = cs.getTransactionState(send.getTransactionId());
                        if (transactionState != null) {
                            transactionState.addCommand(send);
                            
                            if (trackTransactionProducers) {
                                // for jmstemplate, track the producer in case it is closed before commit
                                // and needs to be replayed
                                SessionState ss = cs.getSessionState(producerId.getParentId());
                                ProducerState producerState = ss.getProducerState(producerId);
                                producerState.setTransactionState(transactionState);            
                            }
                        }
                    }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

        TransactionId[] preparedTransactions = broker.getPreparedTransactions(context);
        return new DataArrayResponse(preparedTransactions);
    }


    public Response processMessage(Message messageSend) throws Exception {
        ProducerId producerId = messageSend.getProducerId();
        ProducerBrokerExchange producerExchange = getProducerBrokerExchange(producerId);
        if (producerExchange.canDispatch(messageSend)) {
            broker.send(producerExchange, messageSend);
        }
        return null;

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

            } catch (Throwable e) {
                LOG.warn("Failed to remove consumer: " + consumerId + ". Reason: " + e, e);
            }
        }
        for (Iterator iter = session.getProducerIds().iterator(); iter.hasNext();) {
            ProducerId producerId = (ProducerId) iter.next();
            try {
                processRemoveProducer(producerId);
            } catch (Throwable e) {
                LOG.warn("Failed to remove producer: " + producerId + ". Reason: " + e, e);
            }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId


    /**
     * @return
     */
    protected ProducerId getNextProducerId() {
        return new ProducerId(info.getSessionId(), producerIdGenerator.getNextSequenceId());
    }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

     */
    public boolean isDuplicate(final MessageId id) {
        boolean answer = false;
        
        if (id != null) {
            ProducerId pid = id.getProducerId();
            if (pid != null) {
                BitArrayBin bab = map.get(pid);
                if (bab == null) {
                    bab = new BitArrayBin(auditDepth);
                    map.put(pid, bab);

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

     * 
     * @param id
     */
    public void rollback(final  MessageId id) {
        if (id != null) {
            ProducerId pid = id.getProducerId();
            if (pid != null) {
                BitArrayBin bab = map.get(pid);
                if (bab != null) {
                    bab.setBit(id.getProducerSequenceId(), false);
                }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

     */
    public boolean isInOrder(final MessageId id) {
        boolean answer = false;


        if (id != null) {
            ProducerId pid = id.getProducerId();
            if (pid != null) {
                BitArrayBin bab = map.get(pid);
                if (bab == null) {
                    bab = new BitArrayBin(auditDepth);
                    map.put(pid, bab);

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

        TransactionId[] preparedTransactions = broker.getPreparedTransactions(context);
        return new DataArrayResponse(preparedTransactions);
    }


    public Response processMessage(Message messageSend) throws Exception {
        ProducerId producerId = messageSend.getProducerId();
        ProducerBrokerExchange producerExchange = getProducerBrokerExchange(producerId);
        if (producerExchange.canDispatch(messageSend)) {
            broker.send(producerExchange, messageSend);
        }
        return null;

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.