Hi snyder,
No there are no other subsribers only one subsriber is there, which
recieved the messages
The following is my client program
public class SubscribeTopic {
public static void main(String[] args) throws JMSException {
try{
int index = 0;
ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory("tcp://w.x.y.z:61616");
ActiveMQTopic subTopic = new ActiveMQTopic("OutputTopic");
System.out.println("Connecting to JMS server.");
Connection connection = factory.createConnection();
connection.setClientID("myUniqueClientID");
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
String messageSel = "ActorID = '11111'";
MessageConsumer consumer = session.createDurableSubscriber(subTopic,
"Subscriber1");
connection.start();
while(true){
TextMessage m = (TextMessage) consumer.receive(1000*10);
if( m == null ) {
System.out.println("No messages are available in the
Topic.");
} else {
//Writing the output into file
String fileName = "C:\\xml\\output\\Response"+ index++
+".xml";
BufferedWriter out = new BufferedWriter(new
FileWriter(
fileName));
out.write(m.getText());
out.close();
System.out.println("Response was:
"+m.getText());
}
}
}
catch (Exception e) {
System.out.println("Exception! " + e.getMessage());
}
}
}
bsnyder wrote:
>
> On 6/12/07, Arif Mohd <[EMAIL PROTECTED]> wrote:
>>
>> Hi Gert,
>> Once we subsribe the message from topic, it is not being deleted from the
>> topic though AUTO_ACKNOWLEDGE is set on client side. Is this a bug? or we
>> need to do some configuration in xbean.xml
>
> Are there any other subscribers to the topic that have not yet
> received the message? Also, what options are enabled on the client
> connection to the broker? Can you show me the options you've set via
> either the Java API or via the URI options? Without paring this down
> to a minimal test case, it's difficult to say why this would occur. I
> can tell you that there are no bugs filed on this sort of issue.
>
> Bruce
> --
> perl -e 'print
> unpack("u30","D0G)[EMAIL PROTECTED]&5R\"F)R=6-E+G-N>61E<D\!G;6%I;\"YC;VT*"
> );'
>
> Apache Geronimo - http://geronimo.apache.org/
> Apache ActiveMQ - http://activemq.org/
> Apache ServiceMix - http://servicemix.org/
> Castor - http://castor.org/
>
>
--
View this message in context:
http://www.nabble.com/servicemix-Hanging-tf3899807s12049.html#a11092996
Sent from the ServiceMix - User mailing list archive at Nabble.com.
