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

        }
    }


    public void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception {
        super.removeProducer(context, info);
        ProducerId producerId = info.getProducerId();
        if (redrawOnRemove) {
            synchronized (lock) {
                producerDestinations.remove(producerId);
                producers.remove(producerId);
            }

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

     */
    public synchronized 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 synchronized 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 synchronized 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

    private void writeObject(Object object) throws IOException {
        openWireformat.marshal(object, ds);
    }
    
    protected DataStructure createDataStructure(long index) {
        ProducerId id = new ProducerId();
        id.setConnectionId(connectionId);
        id.setSessionId(index);
        id.setValue(index);
        
        ProducerInfo object = new ProducerInfo();
        object.setProducerId(id);
        object.setDestination(destination);
        return object;

View Full Code Here

Examples of org.apache.activemq.command.ProducerId

    
    protected void assertDataStructureExpected(DataStructure object, long i) {
        assertEquals("Type of object for index: " + i, ProducerInfo.class, object.getClass());
        ProducerInfo command = (ProducerInfo) object;
        
        ProducerId id = command.getProducerId();
        assertNotNull("ProducerID for object at index: " + i, id);
        
        assertEquals("connection ID in object: "+ i, connectionId, id.getConnectionId());
        String actual = Long.toHexString(id.getValue());
        String expected = Long.toHexString(i);
        assertEquals("value of object: "+ i + " was: " + actual, expected, actual);
        assertEquals("value of object: "+ i + " was: " + actual, i, id.getSessionId());
    }

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


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

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


    HashMap<ProducerId, boolean[]> tracker = new HashMap<ProducerId, boolean[]>();
    private synchronized void track(Message message) {
        try {
            MessageId id = new MessageId(message.getJMSMessageID());
            ProducerId pid = id.getProducerId();
            int seq = (int)id.getProducerSequenceId();
            boolean[] ids = tracker.get(pid);
            if (ids == null) {
                ids = new boolean[TO_SEND + 1];
                ids[seq] = true;

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.