Package org.apache.qpid.server.cluster.util

Examples of org.apache.qpid.server.cluster.util.LogMessage

54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
        if(ClusteredQueue.isFromBroker(msg))
        {
            //if message is from another broker, it should only be delivered
            //to another client to meet ordering constraints
            Subscription s = super.nextSubscriber(msg);
            _logger.info(new LogMessage("Returning next *client* subscriber {0}", s));
            if(s == null)
            {
                //TODO: deliver to another broker, but set the redelivered flag on the msg
                //(this should be policy based)

                //for now just don't deliver it
                return null;
            }
            else
            {
                return s;
            }
        }
        Subscription s = _all.nextSubscriber(msg);
        _logger.info(new LogMessage("Returning next subscriber {0}", s));
        return s;
    }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
    {
        if (ClusteredProtocolSession.canRelay(msg, _target))
        {
            try
            {
                _logger.debug(new LogMessage("Relaying {0} to {1}", msg, _target));
                relay(msg);
            }
            catch (NoConsumersException e)
            {
                throw e;
            }
            catch (AMQException e)
            {
                //TODO: sort out exception handling...
                e.printStackTrace();
            }
        }
        else
        {
            _logger.debug(new LogMessage("Cannot relay {0} to {1}", msg, _target));
        }
    }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
58
59
        if(!members.contains(_subject))
        {
            try
            {
                _queue.delete();
                _logger.info(new LogMessage("Deleted {0} in response to exclusion of {1}", _queue, _subject));
            }
            catch (AMQException e)
            {
                _logger.info(new LogMessage("Failed to delete {0} in response to exclusion of {1}: {2}", _queue, _subject, e), e);
            }
        }
    }
View Full Code Here
61
62
63
64
65
66
67
68
        _subscriptions = ((ClusteredSubscriptionManager) getSubscribers()).getAllSubscribers();
    }

    public void deliver(AMQMessage message) throws AMQException
    {
        _logger.info(new LogMessage("{0} delivered to clustered queue {1}", message, this));
        super.deliver(message);
    }
View Full Code Here
92
93
94
95
96
97
98
99
100
        _groupMgr.broadcast(new SimpleSendable(request));
    }

    public void addRemoteSubcriber(MemberHandle peer)
    {
        _logger.info(new LogMessage("Added remote subscriber for {0} to clustered queue {1}", peer, this));
        //find (or create) a matching subscriber for the peer then increment the count
        getSubscriber(key(peer), true).increment();
    }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        _localRecorders.put(ExchangeDeleteBody.class, new ExchangeDeleteRecorder());
    }

    public void methodReceived(AMQStateManager stateMgr, QueueRegistry queues, ExchangeRegistry exchanges, AMQProtocolSession session, AMQMethodEvent evt) throws AMQException
    {
        _logger.debug(new LogMessage("Replay store received {0}", evt.getMethod()));
        AMQMethodBody request = evt.getMethod();

        //allow any (relevant) recorder registered for this type of request to record it:
        MethodRecorder recorder = getRecorders(session).get(request.getClass());
        if (recorder != null)
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.cluster.util.LogMessage

  • org.apache.qpid.server.cluster.Broker
  • org.apache.qpid.server.cluster.BrokerGroup
  • org.apache.qpid.server.cluster.ClusteredProtocolHandler
  • org.apache.qpid.server.cluster.DefaultGroupManager
  • org.apache.qpid.server.cluster.handler.ChannelQueueManager
  • org.apache.qpid.server.cluster.handler.LocalQueueDeclareHandler
  • org.apache.qpid.server.cluster.handler.ReplicatingConsumeHandler
  • org.apache.qpid.server.cluster.handler.ReplicatingHandler
  • org.apache.qpid.server.cluster.handler.ReplicatingHandler$Callback
  • org.apache.qpid.server.cluster.MinaBrokerProxy
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.