Package org.codehaus.activemq.message

Examples of org.codehaus.activemq.message.ConnectionInfo

324
325
326
327
328
329
330
331
332
333
334
                            SessionInfo info = (SessionInfo) packet;
                            consumeSessionInfo(info);
                            break;
                        }
                        case Packet.ACTIVEMQ_CONNECTION_INFO : {
                            ConnectionInfo info = (ConnectionInfo) packet;
                            consumeConnectionInfo(info);
                            break;
                        }
                        case Packet.DURABLE_UNSUBSCRIBE : {
                            DurableUnsubscribe ds = (DurableUnsubscribe) packet;
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
     * @param msg
     */
    public void onMessage(Message msg){
        if (msg instanceof ObjectMessage){
            try {
                ConnectionInfo info = (ConnectionInfo)((ObjectMessage)msg).getObject();
                ConnectionAdvisoryEvent event = new ConnectionAdvisoryEvent(info);
                fireEvent(event);
            }
            catch (JMSException e) {
                log.error("Failed to process message: " + msg);
View Full Code Here
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
            return;
        }
       
        this.isConnectionInfoSentToBroker = true;
        ensureClientIDInitialised();
        ConnectionInfo info = new ConnectionInfo();
        info.setClientId(this.clientID);
        info.setHostName(IdGenerator.getHostName());
        info.setUserName(userName);
        info.setPassword(password);
        info.setStartTime(startTime);
        info.setStarted(started.get());
        info.setClosed(closed || closing);
        info.setClientVersion(connectionMetaData.getProviderVersion());
        info.setWireFormatVersion(transportChannel.getCurrentWireFormatVersion());
        if (info.getProperties() != null){
            info.getProperties().setProperty(ConnectionInfo.NO_DELAY_PROPERTY,new Boolean(!useAsyncSend).toString());
        }
        if (quickClose && info.isClosed()){
            asyncSendPacket(info);
        }else {
            syncSendPacket(info, timeout);
        }
    }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
        assertTrue(test.matchProducer(advisory, info));
    }
   
    public void testMatchConnection(){
        String destName = "foo.bar";
        ConnectionInfo info = new ConnectionInfo();
       
       
        ActiveMQTopic advisoryDest = new ActiveMQTopic(ActiveMQDestination.CONNECTION_ADVISORY_PREFIX + destName);
        ConsumerInfo advisory = new ConsumerInfo();
        advisory.setDestination(advisoryDest);
View Full Code Here
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
            return;
        }
       
        this.isConnectionInfoSentToBroker = true;
        ensureClientIDInitialised();
        ConnectionInfo info = new ConnectionInfo();
        info.setClientId(this.clientID);
        info.setHostName(IdGenerator.getHostName());
        info.setUserName(userName);
        info.setPassword(password);
        info.setStartTime(startTime);
        info.setStarted(started.get());
        info.setClosed(closed.get() || closing);
        info.setClientVersion(connectionMetaData.getProviderVersion());
        info.setWireFormatVersion(transportChannel.getCurrentWireFormatVersion());
        if (info.getProperties() != null){
            info.getProperties().setProperty(ConnectionInfo.NO_DELAY_PROPERTY,new Boolean(!useAsyncSend).toString());
        }
        if (quickClose && info.isClosed()){
            asyncSendPacket(info);
        }else {
            syncSendPacket(info, timeout);
        }
    }
View Full Code Here
804
805
806
807
808
809
810
811
812
813
814
815
816
817
            String brokerClientID = createMulticastClientID();
            channel.setClientID(brokerClientID);

            // lets spoof a consumer for topics which will replicate messages
            // over the multicast transport
            ConnectionInfo info = new ConnectionInfo();
            info.setHostName(IdGenerator.getHostName());
            info.setClientId(brokerClientID);
            info.setStarted(true);
            client.consumeConnectionInfo(info);

            ConsumerInfo consumerInfo = new ConsumerInfo();
            consumerInfo.setDestination(new ActiveMQTopic(">"));
            consumerInfo.setNoLocal(true);
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
     * @param msg
     */
    public void onMessage(Message msg){
        if (msg instanceof ObjectMessage){
            try {
                ConnectionInfo info = (ConnectionInfo)((ObjectMessage)msg).getObject();
                ConnectionAdvisoryEvent event = new ConnectionAdvisoryEvent(info);
                fireEvent(event);
            }
            catch (JMSException e) {
                log.error("Failed to process message: " + msg);
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
80
       
    }

    public void onEvent(ConnectionAdvisoryEvent event) {
        System.out.println(event);
        ConnectionInfo info = event.getInfo();
        started.set(info.isStarted());
        synchronized(started){
            started.notify();
        }
       
    }
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
                            SessionInfo info = (SessionInfo) packet;
                            consumeSessionInfo(info);
                            break;
                        }
                        case Packet.ACTIVEMQ_CONNECTION_INFO : {
                            ConnectionInfo info = (ConnectionInfo) packet;
                            consumeConnectionInfo(info);
                            break;
                        }
                        case Packet.DURABLE_UNSUBSCRIBE : {
                            DurableUnsubscribe ds = (DurableUnsubscribe) packet;
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
            for (Iterator i = producers.iterator();i.hasNext();) {
                ProducerInfo info = (ProducerInfo) i.next();
                generateAdvisory(advisory, info);
            }
            for (Iterator i = connections.iterator();i.hasNext();) {
                ConnectionInfo info = (ConnectionInfo) i.next();
                generateAdvisory(advisory, info);
            }
        }
        return result;
    }
View Full Code Here
TOP

Related Classes of org.codehaus.activemq.message.ConnectionInfo

  • org.codehaus.activemq.ActiveMQConnection
  • org.codehaus.activemq.ActiveMQConnectionFactory
  • org.codehaus.activemq.advisories.ConnectionAdvisor
  • org.codehaus.activemq.advisories.ConnectionAdvisorTest
  • org.codehaus.activemq.broker.impl.AdvisorySupport
  • org.codehaus.activemq.broker.impl.AdvisorySupportTest
  • org.codehaus.activemq.broker.impl.BrokerClientImpl
  • org.codehaus.activemq.io.impl.ConnectionInfoReader
  • org.codehaus.activemq.io.impl.ConnectionInfoWriter
    • 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.