Re: Messages being consumed but not delivered to the application

I'm so unbelievably happy that I worked out what was causing this issue! It seems that the two servers I was using had different times set on them. So the receiving machine thought the message was expired, and so rejected it, while the broker itself thought the message was fine, and so hung onto

Re: Securing active MQ

I believe throwing an exception is the right thing to do. Joe Free ActiveMQ User Reference Guide @ http://www.ttmsolutions.com mcarter wrote: > > > >> >> Re #2 - you could write yourself a broker plugin thingy that extends >> BrokerService and implements the addConnection(ConnectionContext

Re: Securing active MQ

> > Re #2 - you could write yourself a broker plugin thingy that extends > BrokerService and implements the addConnection(ConnectionContext context, > ConnectionInfo info) method; within which you can check the IP address of > the remote client making the connection request. > > I've imple

Re: Automatic recovery when using Message Groups

I've filed a Jira enhacement request for this https://issues.apache.org/activemq/browse/AMQ-2106 Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Thu, Feb 12, 2009 at 6:12 PM, kalki70

Re: How to specify SSL Ciphers

"&socket.enabledCipherSuites=..." does not seem to be working. Am I doing something wrong? Also, I can't seem to use the SSLTransportFactory class (which has a "compositeConfigure" method) in conjunction with the ActiveMQConnection class. Any assistance is greatly appreciated. -mrh mrh wrote

Re: Automatic recovery when using Message Groups

Hi, Dejan, I agree consumers don't know which groups they will be assigned. As you said, if a consumer goes down, other will take those groups, but the problem comes when the consumer that went down comes back again. It will never receive any more messages. So what I proposed was something like t

Re: Messages rollback

Thanks very much for the information. For the C/C++ sender and receiver, does stomp provide the similar functionality as JMS session ? Dave Stanley wrote: > > You can created a transacted jms session and either commit() or rollback() > that session. See: > http://svn.apache.org/viewvc/activ

Re: Automatic recovery when using Message Groups

Hi Luis, I'm not sure this is the correct use case. Consumers don't explicitly know what groups they will be assigned to when they first subscribe, so there is usually no difference what consumer is consuming messages from what group. When your consumer goes down, the other one will take its group

Re: Automatic recovery when using Message Groups

Hi, Dejan, My opinion is that the functionality of Message Groups is partially broken if there is no automatic recovery. What should the user do? Restart ActiveMQ ? :-( I don't think it is so hard to implement. Upon subscription the consumer could be informed its consumer id, which can be an opti

Re: Consuming Advisory messages from ActiveMQ using stomp

Hi Uwe, this is not supported at the moment https://issues.apache.org/activemq/browse/AMQ-2098 I hope it will be implemented in one of the following releases Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http

Consuming Advisory messages from ActiveMQ using stomp

Hi all! I am connecting to ActiveMQ using stomp. I need to get the connection information for clients from ActiveMQ. My first thought was to subscribe to /topic/ActiveMQ.Advisory.Connection. Subscription and message receive work, but the payloads of the messages are empty. I receive messages wh

ActiveMQ: many clients, client-to-client, Internet

Dear list I am developing a distributed system with the following characteristics: - many clients (usually online 24/7) - connected via the Internet - mostly direct client-to-client (1:1) communication I am not sure whether ActiveMQ or messaging in general is suitable if the communication is mos

Bytesmessage and http transport

Hi, I'm trying to send a BytesMessage (size : 1 MB max) using HTTP transport but it does not work. In the ActiveMQ console, I get this : java.io.UTFDataFormatException: encoded string too long: 208555 bytes If I switch to openwire TCP, program is working fine ... Is there any message size limi

Re: Automatic recovery when using Message Groups

Hi Luis, unfortunately there is no way for the consumer to recover its previous message groups. I'm not sure how this could be implemented, since the consumer will have a new consumer id upon recovery, so it would be impossible to relate it to the previous subscription. Cheers -- Dejan Bosanac O

Re: Persistence DDL

Hi, you may also check the Statements.java class http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java?view=markup for the complete list of tables, queries issued by ActiveMQ. Cheers -- Dejan Bosanac Open Source Integration - htt

Re: How to Set the header value to the JMS messages

Hi Nawaz, A great place to look for example JMS usage is the activemq test suite. For example, the SelectorTest shows how message properties can be set and consumed based on property values: see: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSel

Re: Q Consumers stop receiving messages

Gary Tully wrote: > > in transacted mode, who is managing the transaction demarcation? In > other words, where is the session.commit() call? > it turns out that this issue was not related to the other issues in this thread. i had failed to make the message-producers commit and this was respon