You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "jim yu (JIRA)" <ji...@apache.org> on 2010/04/26 12:33:25 UTC
[jira] Created: (AMQNET-249) Is API Receive having ordering
problem?
Is API Receive having ordering problem?
---------------------------------------
Key: AMQNET-249
URL: https://issues.apache.org/activemq/browse/AMQNET-249
Project: ActiveMQ .Net
Issue Type: Bug
Components: NMS
Affects Versions: 1.1.0
Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
Reporter: jim yu
Assignee: Jim Gomes
Hi, All,
If try the following steps, the API receive won't work normally..
1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
2. Start a connection from the sender to activemq first.
3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
4. Call request.send (API Send) to send a message to activemq in sender.
5. The data will be drop by activemq but Receiver will never get data from activemq.
However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQNET-249) Is API Receive having ordering
problem?
Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59147#action_59147 ]
Timothy Bish commented on AMQNET-249:
-------------------------------------
For version 1.2.0 onward you should need any config files, just ensure that the NMS and NMS.ActiveMQ DLLs are located together and referenced by you studio project.
I don't see anything wrong in the code you sent and this is functionality that is tested and working here so I don't know, if you can attach a test case that reproduces the issue we can take a look.
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQNET-249) Is API Receive having ordering
problem?
Posted by "jim yu (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59123#action_59123 ]
jim yu commented on AMQNET-249:
-------------------------------
Hi, Timothy,
Thanks for your reply and the information, but I think I am using a queue not a topic. The following is the code I using to send the msg...
Please kind help me if you know what's wrong this code...
PS: Another issue, say Sender is runing, but Receiver is off. When Sender sent a message to the queue, I should be able to see a pending message in queue from the web console, but I didn't see any. Please help me if you know about this. Thanks a lot!
Sender
--------------------------------------------------------------------------------------
Dim properties As Apache.NMS.IPrimitiveMap
Dim connection As IConnection
Dim session As ISession
Dim destination As IDestination
Dim consumer As IMessageConsumer
Dim producer As IMessageProducer
Dim oTimeout As TimeSpan
Dim factory As IConnectionFactory
Dim ConnURI As Uri
ConnURI = New Uri("activemq:tcp://localhost:61616")
factory = New NMSConnectionFactory(ConnURI)
connection = factory.CreateConnection()
session = connection.CreateSession()
connection.Start()
oTimeout = New TimeSpan(1)
destination = Util.SessionUtil.GetDestination(session, "queue://TESTMQ")
consumer = session.CreateConsumer(destination)
producer = session.CreateProducer(destination)
request = session.CreateTextMessage("Test Msg...")
properties = request.Properties
properties.Item("NMSXGroupID") = "TEST"
request.NMSCorrelationID = "ID0001"
producer.RequestTimeout = oTimeout
producer.TimeToLive = oTimeout
producer.Send(request)
------------------------------------------------------------------------------------------------------------------------------
Receiver
------------------------------------------------------------------------------------------------------------------------------
Dim connection As IConnection
Dim session As ISession
Dim destination As IDestination
Dim consumer As IMessageConsumer
Dim producer As IMessageProducer
Dim factory As IConnectionFactory
Dim ConnURI As Uri
Dim oRecMsg As Apache.NMS.IMessage
ConnURI = New Uri("activemq:tcp://localhost:61616")
factory = New NMSConnectionFactory(ConnURI)
connection = factory.CreateConnection()
session = connection.CreateSession()
destination = Util.SessionUtil.GetDestination(session, "queue://" & txtMQName.Text)
consumer = session.CreateConsumer(destination)
producer = session.CreateProducer(destination)
connection.Start()
oRecMsg = consumer.Receive()
------------------------------------------------------------------------------------------------------------------------------
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQNET-249) Is API Receive having ordering
problem?
Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59124#action_59124 ]
Timothy Bish commented on AMQNET-249:
-------------------------------------
First thing I'd recommend is that you upgrade to NMS 1.2.0 as that is the latest stable release.
I notice you are setting a Time to Live on the message, you should make sure its not being set to short and that the clocks on the machines are all in sync.
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQNET-249) Is API Receive having ordering
problem?
Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59089#action_59089 ]
Timothy Bish commented on AMQNET-249:
-------------------------------------
Sounds like you are using Topics, this is normal behavior for a Topic based message channel. See:
http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Closed: (AMQNET-249) Is API Receive having ordering problem?
Posted by "jim yu (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
jim yu closed AMQNET-249.
-------------------------
Fix Version/s: 1.2.0
Resolution: Fixed
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Fix For: 1.2.0
>
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQNET-249) Is API Receive having ordering
problem?
Posted by "jim yu (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59247#action_59247 ]
jim yu commented on AMQNET-249:
-------------------------------
Hi, Tim,
Sorry for forgetting to close this issue. It's okay to use vresion 1.2.0.xxx now.
Thanks agian.
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQNET-249) Is API Receive having ordering
problem?
Posted by "jim yu (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59139#action_59139 ]
jim yu commented on AMQNET-249:
-------------------------------
Hi,
Thanks for your replay.
I was using NMS 1.2.0 at first time. But I kept getting the error "No IConnectionFactory implementation found for connection URI: activemq:tcp://localhost:61616" when it ran to factory = New NMSConnectionFactory(ConnURI, "TESTMQ").
I've searched the article related to this issue and copied files "nmsprovider-activemq.xml", "nmsprovider-tcp.xml", "nmsprovider-test.xml" to the specific folder.
However, I got the same error.
Did I do any step wrong or miss anything in above code? It works fine in NMS 1.1.0 but got exceptation in NMS1.2.0.
I did the test in my local machine, I believe there should be no sync. problem.
Because the message sent from Sender never kept in pending queue so I just tried to set a time to live.
I've tried to set it from 1 to 10000, but the message disappeared immediately still. Have any idea about this?
Thanks again.
> Is API Receive having ordering problem?
> ---------------------------------------
>
> Key: AMQNET-249
> URL: https://issues.apache.org/activemq/browse/AMQNET-249
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: NMS
> Affects Versions: 1.1.0
> Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP
> Reporter: jim yu
> Assignee: Jim Gomes
> Original Estimate: 1 hour
> Remaining Estimate: 1 hour
>
> Hi, All,
> If try the following steps, the API receive won't work normally..
> 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq.
> 2. Start a connection from the sender to activemq first.
> 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq.
> 4. Call request.send (API Send) to send a message to activemq in sender.
> 5. The data will be drop by activemq but Receiver will never get data from activemq.
> However, API Receive will work normally if start the receiver first and then start the sender.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.