.NET Client is not receiving messages
-------------------------------------
Key: AMQNET-131
URL: https://issues.apache.org/activemq/browse/AMQNET-131
Project: ActiveMQ .Net
Issue Type: Bug
Components: ActiveMQ Client
Environment: 1. Java Producer using Mule placing Messages into Queue.
2. ActiveMQ on JBoss web server, running on Linux
3. .NET Consumer running as Windows Service on Windows 2003 server
Reporter: Sanjeev
Assignee: Jim Gomes
Priority: Critical
I am using IMessageConsumer to receive messages from the queue using NMS on
.NET.
The listener is dying periodically within half-hour. I could see messages in
the queue. But .NET Listener is not getting any messages.
The messages are arriving after I restart the service.
Please find below the code I am using
Imports System
Imports System.Collections.Generic
Imports System.Text
Imports System.Configuration
Imports System.Threading
Imports ActiveMQ
Imports Spring.Messaging.Nms
Imports Spring.Messaging.Nms.Listener
Imports Business.RIO.Business
Imports BusinessEntities.RIO.Entities
Imports Exceptions.RMSExceptions
Imports Utils.RIO.Utils
Imports NMS
Imports System.Xml
Imports System.Timers
Namespace ListenerConsole
Public Class InterfaceBaseHelper
#Region "Private Variables"
Private config As ConfigurationEntity
#End Region
Public Sub New()
config = New ConfigurationEntity()
config.ServerName = ConfigurationManager.AppSettings("ServerName")
config.LocationQueueName =
ConfigurationManager.AppSettings("LocationQueueName")
config.CustQueueName =
ConfigurationManager.AppSettings("CustomerQueueName")
config.WOQueueName = ConfigurationManager.AppSettings("WOQueueName")
config.MeterQueueName =
ConfigurationManager.AppSettings("MeterQueueName")
config.InfraQueueName =
ConfigurationManager.AppSettings("InfraQueueName")
config.LocationAckQueueName =
ConfigurationManager.AppSettings("LocationAcknowledgementQueueName")
config.MeterAckQueueName =
ConfigurationManager.AppSettings("MeterAcknowledgementQueueName")
config.WOAckQueueName =
ConfigurationManager.AppSettings("WOAcknowledgementQueueName")
config.InfraAckQueueName =
ConfigurationManager.AppSettings("InfraAcknowledgementQueueName")
config.CustAckQueueName =
ConfigurationManager.AppSettings("CustAcknowledgementQueueName")
config.ErrorQueueName =
ConfigurationManager.AppSettings("ErrorQueueName")
config.ServerPollingIntervalInSeconds =
Convert.ToInt32(ConfigurationManager.AppSettings("ServerConnectionPollingIntervalInSeconds"))
facade = New RIOFacade(config)
End Sub
Dim timer As System.Timers.Timer
Dim facade As RIOFacade
''' <summary>
''' Starts all queues
''' </summary>
''' <remarks></remarks>
Public Sub ServiceStartUp()
Try
timer = New System.Timers.Timer()
timer.Interval = config.ServerPollingIntervalInSeconds * 1000
timer.Enabled = True
OpenConnections()
AddHandler timer.Elapsed, (AddressOf StartConnections)
timer.Start()
Catch ex As Exception
ExceptionManager.HandleException(ex)
RIOHelper.LogException(ex)
End Try
End Sub
Dim lookupsCached As Boolean = False
Private Sub OpenConnections()
Try
ListenLocationQueueMessaage()
ListenMeterQueueMessaage()
ListeninfraQueueMessaage()
ListenWOQueueMessaage()
RIOHelper.LogMessage("Connections Started.")
Catch ex As Exception
RIOHelper.LogMessage(ex.Message)
ExceptionManager.HandleException(ex)
End Try
End Sub
Private Sub StartConnections(ByVal sender As Object, ByVal e As
ElapsedEventArgs)
Try
timer.Stop()
CloseConnections()
OpenConnections()
Catch ex As Exception
RIOHelper.LogMessage(ex.Message)
ExceptionManager.HandleException(ex)
End Try
timer.Start()
End Sub
Private Sub CloseConnections()
locConnectionFactory = Nothing
locConsumer.Close()
locConsumer.Dispose()
locSession.Close()
locSession.Dispose()
locConnection.Close()
locConnection.Dispose()
mtrConnectionFactory = Nothing
mtrConsumer.Close()
mtrConsumer.Dispose()
mtrSession.Close()
mtrSession.Dispose()
mtrConnection.Close()
mtrConnection.Dispose()
woConnectionFactory = Nothing
woConsumer.Close()
woConsumer.Dispose()
woSession.Close()
woSession.Dispose()
woConnection.Close()
woConnection.Dispose()
infraConnectionFactory = Nothing
infraConsumer.Close()
infraConsumer.Dispose()
infraSession.Close()
infraSession.Dispose()
infraConnection.Close()
infraConnection.Dispose()
End Sub
#Region "Listerners"
Dim locConnectionFactory As ConnectionFactory
Dim locConnection As IConnection
Dim locSession As ISession
Dim locConsumer As IMessageConsumer
''' <summary>
''' Listener for Location queue
''' </summary>
''' <remarks></remarks>
Private Sub ListenLocationQueueMessaage()
locConnectionFactory = New ConnectionFactory(config.ServerName)
locConnection = locConnectionFactory.CreateConnection()
locSession = locConnection.CreateSession()
locConsumer =
locSession.CreateConsumer(locSession.GetQueue(config.LocationQueueName))
AddHandler locConsumer.Listener, (AddressOf HandleLocation)
End Sub
Private Sub HandleLocation(ByVal message As IMessage)
facade.ProcessLocation(TryCast(message, ITextMessage).Text)
End Sub
Dim mtrConnectionFactory As ConnectionFactory
Dim mtrConnection As IConnection
Dim mtrSession As ISession
Dim mtrConsumer As IMessageConsumer
''' <summary>
''' Listener for Meter queue
''' </summary>
''' <remarks></remarks>
Private Sub ListenMeterQueueMessaage()
mtrConnectionFactory = New ConnectionFactory(config.ServerName)
mtrConnection = mtrConnectionFactory.CreateConnection()
mtrSession = mtrConnection.CreateSession()
mtrConsumer =
mtrSession.CreateConsumer(mtrSession.GetQueue(config.MeterQueueName))
AddHandler mtrConsumer.Listener, (AddressOf HandleMeter)
End Sub
Private Sub HandleMeter(ByVal message As IMessage)
facade.ProcessMeter(TryCast(message, ITextMessage).Text)
End Sub
Dim woConnectionFactory As ConnectionFactory
Dim woConnection As IConnection
Dim woSession As ISession
Dim woConsumer As IMessageConsumer
''' <summary>
''' Listener for WorkOrder queue
''' </summary>
''' <remarks></remarks>
Private Sub ListenWOQueueMessaage()
woConnectionFactory = New ConnectionFactory(config.ServerName)
woConnection = woConnectionFactory.CreateConnection()
woSession = woConnection.CreateSession()
woConsumer =
woSession.CreateConsumer(woSession.GetQueue(config.WOQueueName))
AddHandler woConsumer.Listener, (AddressOf HandleWO)
End Sub
Private Sub HandleWO(ByVal message As IMessage)
facade.ProcessWO(TryCast(message, ITextMessage).Text)
End Sub
Dim infraConnectionFactory As ConnectionFactory
Dim infraConnection As IConnection
Dim infraSession As ISession
Dim infraConsumer As IMessageConsumer
''' <summary>
''' Listener for Infra queue
''' </summary>
''' <remarks></remarks>
Private Sub ListeninfraQueueMessaage()
infraConnectionFactory = New ConnectionFactory(config.ServerName)
infraConnection = infraConnectionFactory.CreateConnection()
infraSession = infraConnection.CreateSession()
infraConsumer =
infraSession.CreateConsumer(infraSession.GetQueue(config.InfraQueueName))
AddHandler infraConsumer.Listener, (AddressOf HandleInfra)
End Sub
Private Sub HandleInfra(ByVal message As IMessage)
facade.ProcessInfra(TryCast(message, ITextMessage).Text)
End Sub
#End Region
End Class
End Namespace
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
