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 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

    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

        int count = 10000;
        ActiveMQMessageAudit audit = new ActiveMQMessageAudit();
        // add to a list
        List<MessageReference> list = new ArrayList<MessageReference>();
        for (int i = 0; i < count; i++) {
            ProducerId pid = new ProducerId();
            pid.setConnectionId("test");
            pid.setSessionId(0);
            pid.setValue(1);
            MessageId id = new MessageId();
            id.setProducerId(pid);
            id.setProducerSequenceId(i);
            ActiveMQMessage msg = new ActiveMQMessage();
            msg.setMessageId(id);

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


    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.