MessageAuthorizationPolicy does not work??

BrokerService service=BrokerFactory.createBroker(new URI("xbean:activemq.xml")); service.setMessageAuthorizationPolicy(new MyMessageAuthorizationPolicy()); am I worong ?? -- View this message in context: http://www.nabble.com/MessageAuthorizationPolicy-does-not

How to configurate MessageAuthorizationPolicy in activemq.xml ?

http://activemq.org/config/1.0"/> Then can not start the ActiveMQ broker call for help.. thx. -- View this message in context: http://www.nabble.com/How-to-configurate-MessageAuthorizationPolicy-in-activemq.xml---tf4302997s2354.html#a12248232 Sent from the ActiveMQ

active mq (message expiration)

Hello Active MQ users/developers , Our application uses non persistent embedded broker ,durable subscribers , topic publishers . The active mq version is 4.1.1(release version). There are two topic publishers and two durable subscribers respectively. In your previou

Re: How to Retrieve Message Properties

I can set/get both String and Int properties on a TextMessage just fine. I am using AMQ 4.1.1 Joe RobBugh wrote: > > I can get around the problem if I use a MapMessage instead of a > TextMessage. Is this correct behavior though? Shouldn't I still be able to > set/get properties on a TextMessa

Re: Simple networkConnector question

Hey, thx for the hint. Funny, i always used it like that, but i always thought this would be some kind of dirty hack and there would be a "clean" way to set up broker connections...:-) ttmdev wrote: > > transportConnector elements are used by brokers to listen for and accept > connectio

Re: How to Retrieve Message Properties

I can get around the problem if I use a MapMessage instead of a TextMessage. Is this correct behavior though? Shouldn't I still be able to set/get properties on a TextMessage? RobBugh wrote: > > I'm having problems retrieving custom properties set on TextMessages. I > have a persistent queue to

message expiration and 5.0.0 snap shot version

Hello Active MQ users/developers , Our application is currently using Actiive MQ 4.1.1 version. We have an embedded broker in Tomcat 5.5 , without persistence , durable subscribers and Topic publishers , with a time to live of 5 minutes for the messages. I have observed th

Re: Simple networkConnector question

transportConnector elements are used by brokers to listen for and accept connection requests from clients and other brokers. Joe j0llyr0g3r wrote: > > Hi folks, > > i got a really simple question and i hope someone can help me out. > > I simply don't get it: I just want to connect two br

How to Retrieve Message Properties

I'm having problems retrieving custom properties set on TextMessages. I have a persistent queue to pass messages between a simple producer and consumer. The producer sets several properties on a TextMessage such as, TextMessage message = m_session.createTextMessage("EMSSyncRequest");

Simple networkConnector question

Hi folks, i got a really simple question and i hope someone can help me out. I simply don't get it: I just want to connect two brokers, let's call them A and B. Ok, so my broker A looks like this: Simple thing. Listen on 61610 for consumers and

Re: ApacheCon

On 8/20/07, ttmdev <[EMAIL PROTECTED]> wrote: > > Bruce, > > Are your presentation slides on AMQ publicly available and if so can you > please direct us to them? I've attached them for you and I've CC'd you directly because the MLM will strip the attachment. Bruce -- perl -e 'print unpack("u30",

Re: ApacheCon

Bruce, Are your presentation slides on AMQ publicly available and if so can you please direct us to them? Thanks. bsnyder wrote: > > On 8/17/07, Brian Munroe <[EMAIL PROTECTED]> wrote: >> On 8/15/07, Bruce Snyder <[EMAIL PROTECTED]> wrote: >> >> > >> > It's all the luck of the draw really. We

Re: Temporary destinations with given destination name

James, I have implemented the plugin that 1) runs on the predefined schedule 2) cleans all the destinations that are without producers, consumers and pending messages 3) will start after defined delay so to avoid removing destinations defined through configuration file. Would like contribute th

Re: What are version 5.0 release dates?

Any responses? xbranko wrote: > > What are the release dates for version 5.0? Even having tentative dates > (with no obligations or strings attached) would be great. > > Thanks, > Branko > -- View this message in context: http://www.nabble.com/What-are-version-5.0-release-dates--tf3984671s

Re: How to delete a queue?

You could just use the web console to remove the queue? On 8/20/07, bill richard <[EMAIL PROTECTED]> wrote: > > hi,all > i m using activeMq recently.And now i need to delete a named queue,which is > created like this: > session.createQueue(Name); > and i want to remove this queue. > And i have fo

Re: How to delete a queue?

On 8/20/07, bill richard <[EMAIL PROTECTED]> wrote: > > hi,all > i m using activeMq recently.And now i need to delete a named queue,which is > created like this: > session.createQueue(Name); > and i want to remove this queue. > And i have found that this work can be done with jmx.but i have no ide

How to delete a queue?

hi,all i m using activeMq recently.And now i need to delete a named queue,which is created like this: session.createQueue(Name); and i want to remove this queue. And i have found that this work can be done with jmx.but i have no idea with BrokerService and ManagedRegionBroker which are the constr

Re: Message expiration on but queue only growing?

What would it take to get this in AMQ? Is this something you guys could do if it were a sponsored task? On 8/20/07, Rob Davies <[EMAIL PROTECTED]> wrote: > we dont actively try and purge messages from storage yet - only when > they are paged in from store to process (e.g. if there is a consumer >

RE: Error on starting QueueConnection

New test done ! I have put this code into my first project. If i try to create a Connection, a Session and a Consumer there is no problem at all. But if i create a QueueConnection, a QueueSession and a QueueReceiver i got the "error". the QueueConnection is corretly create but the QueueSession not

Clustering not working: JMS-Exception

Hey folks, i am having a hard time trying to find out how clustering works seamlessly with amq. Imagine the following situation: -> One cluster consisting of a master and a slave broker -> One consumer and one producer -> Persistence / Clustering mechanism is filesystem-based via shared storage

RE: Error on starting QueueConnection

Here is my new investigation : I create a new project! I only implement one class which implements ServletContextListener and MessageListener, and wrote this so simple code : public class ActiveMQBrokerStartListener implements ServletContextListener, MessageListener { BrokerService broke

Network Brokers probleam

hi: my activemq.xml what can i do when i sent a topic message to tcp://192.168.1.156:61616 ,this message can receive from host2? the Network Brokers only use in queue? -- View this message in context: http://www.nabble.com/Network-Brokers-probleam-tf4297571s2354.html#a12232398

unregister

denez wrote: I try your both sample, but it still doesn't work. I try to move my project directory because originally contains space. but still have the same error. I probaly miss something in my configuration or someting is wrong in my code. I don't understand. So, could you give me or send me

Stomp property "expires" doesn't work on AMQ4.2

Hi folk, I have used a stomp client with *apache-activemq-4.2-20070607.230602-81. *I sent and then received messages from a same queue. But when I send with an * expires *header set of non-zero value, I can't get the message I sent. It works properly when *expires *is set to 0 or with AMQ version

is it possible to unsubscribe a durable subscriber when it is still consuming??

in our project, we need to provide the power for the server to kick out some subscribers no matter whether they are still consuming or not.. how to implement this ? Thanks for reading this message.. -- View this message in context: http://www.nabble.com/is-it-possible-to-unsubscribe-a-durable-su

RE: Error on starting QueueConnection

I try your both sample, but it still doesn't work. I try to move my project directory because originally contains space. but still have the same error. I probaly miss something in my configuration or someting is wrong in my code. I don't understand. So, could you give me or send me a sample web ap