many consumers in JMS queue

Similar Questions

• That could limit the number of MDB instances in the JMS queue?

  Hi all, I have an app that publish messages in a JMS queue. In SD in the MDB, I defined the following:
  
  < wls:ejb - name > VfDataMiner < / wls:ejb - name >
  < wls:message - driven-descriptor >
  < wls:pool >
  < wls:max - beans-in-free-pool > 25 < / wls:max - beans-in-free-pool >
  < wls: initial-beans-in-free-pool > 10 < / wls: initial-beans-in-free-pool >
  < / wls:pool >
  < / wls:message - driven-descriptor >
  
  My understanding is that this should create up to 25 multilateral development banks to process messages when necessary and that number will fall to 10 if there is no traffic. However, it does not appear so as I saw that 16 consumers at all times.
  
  At first, I thought it might be that the server is running out of threads to spawn new BMD so I also added the thread pool using the - Dweblogic.threadpool.MinPoolSize = 100 in the start, but it is always showing 16 consumers. I miss any idea what else do you? I use this on WLS 11 g.
  
  Thanks in advance for the advice/pointers.

  http://download.Oracle.com/docs/CD/E12840_01/WLS/docs103/EJB/message_beans.html

  The number of MDB instances in the free pool is limited by the value of the element of max-beans-in free-pool in memory of weblogic-ejb - jar.xml and available. The value of max-beans-in free-pool is > determined by the following rules, in order of precedence:

  If a custom ExecuteThreadPool is set, the number of threads MDB is identical to the value of ExecuteThreadCount.
  If a WorkManager customized with max-son-constraint is defined, then the number of threads MDB is identical to the value of max-son-stress.
  If the autotune option is disabled, the number of threads MDB is equal to the:
  (ExecuteThreadCount / 2) + 1

  The number of threads MDB is equal to 16 (this is the default).

  If you want more of 16 sons define a handler for a custom job and associate it with the strategy of sending of the mdb.

• (XML-based) SMS sending to the JMS queue

  Hi gurus,

  How we can publish a text message in the JMS queue using message text option by writing to Java or PL/SQL according to the following XML schema definition:

  <? XML version = "1.0" encoding = "windows-1252"? >

  " < xsd: Schema container = ' http://www.w3.org/2001/XMLSchema "

              xmlns=" http://www.example.org "

  " targetNamespace = ' http://www.example.org "

  elementFormDefault = "qualified" >

  < xsd: element name = "Employee" >

  < xsd: annotation >

  < xsd: documentation >

  An element of the sample

  < / xsd: documentation >

  < / xsd: annotation >

  < xsd: complexType >

  < xsd: SEQUENCE >

  < xsd: element name = "EmpNo" type = "xsd: Decimal" / >

  < xsd: element name = "EmpName" type = "xsd: String" / >

  < xsd: element name = "Salary" type = "xsd: double" / >

  < / xsd: SEQUENCE >

  < / xsd: complexType >

  < / xsd: element >

  < / xsd: Schema >

  My Composite SOA will contain a JMS as a Service exposed adapter.

  Hello

  Please find enclosed the attachment for an example implementation of the Java client code to post the message to a weblogic JMS queue.

  It will be useful.

• Issue, while reading the file data from a JMS queue

  Hello

  I'm trying a simple case to receive the XML of the JMS queue and inside BPEL use Assign activity to read data in a temporary variable to check the file from the JMS queue. I do the archive file name, CHRAPcXMLInvoices_DUNS_XXXXXXX_datestamp.dat, XXXXXX as the mapping of the identity of the XML from the JMS queue. Some reasons is not mapping... Can someone help me on this please? I stuck here because my final requirement was to insert the data from the XML file in a custom table, but because of this, it fails saying "can not insert a null" which means that some how he does not read the data...

  I enclose the screen... Please help...

  Hello

  I would try to replicate the same at my end, but you can do the following to me.

  You could manually put the message ("but add xmlns ="http://www.example.org" in cXML item payloadID") in the JMS and test it.

  For Ex:

  " xmlns ="http://www.example.org">"

  The XML message is clearly the namespace XSD lacks. The BPEL is looking in the correct namespace (xmlns:ns3 ="http://www.example.org" ") of the XML message, but as space of names are not added to the incoming message sound throw an exception.

  So, try to add the namespace to the XML message and publish manually in the JMS queue to start the process.

• Integrate CEP with weblogic JMS queue

  Hi guys,.

  I am trying to send data of CEP to the of Weblogic JMS queue, but I get the error message

  
  Error:

  org.springframework.beans.FatalBeanException: error initializing the context lifecycle; nested exception is java.lang.IllegalArgumentException: failed to find JNDI for jms/CEP_Q1 of the t3://10.80.4.206:7001 provider

  at com.bea.wlevs.spring.ApplicationContextLifecycle.onApplicationEvent(ApplicationContextLifecycle.java:146)

  to org.springframework.context.event.SimpleApplicationEventMulticaster$ 1.run(SimpleApplicationEventMulticaster.java:79)

  at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50)

  at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76)

  at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274)

  at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:737)

  at org.springframework.osgi.context.support.AbstractOsgiBundleApplicationContext.finishRefresh(AbstractOsgiBundleApplicationContext.java:235)

  to org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$ 4.run(AbstractDelegatedExecutionApplicationContext.java:358)

  at org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)

  at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:320)

  to org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$ CompleteRefreshTask.run (DependencyWaiterApplicationContextExecutor.java:139)

  at org.springframework.scheduling.commonj.DelegatingWork.run(DelegatingWork.java:62)

  to weblogic.work.commonj.CommonjWorkManagerImpl$ WorkWithListener.run (CommonjWorkManagerImpl.java:204)

  to weblogic.work.SelfTuningWorkManagerImpl$ WorkAdapterImpl.run (SelfTuningWorkManagerImpl.java:545)

  at weblogic.work.ExecuteThread.execute(ExecuteThread.java:256)

  <jms-adapter>
    <name>CreditCardJMSOutboundAdapter</name>
    <event-type>CreditCardEvent</event-type>
    <jndi-provider-url>t3://10.80.4.206:7001</jndi-provider-url>
    <destination-jndi-name>jms/CEP_Q1</destination-jndi-name>
    <user>admin</user>
    <password>welcome1</password>
    </jms-adapter>
  

  In the weblogic server:

  The JMS adapter resources outgoing connection JNDI adapter: eis/queue / CEP

  ConnectionFactoryLocation: jms/OCEP_CF

  Connection factory JNDI name: jms/OCEP_CF

  JNDI queue name: jms/CEP_Q1

  
  

  Advice me please.

  
  

  Thank you

  Yatan
  

  Hi guys, this solved, the problem was that I was using the wrong port of JNDI, my queue was targeting the soa-server1 on 8001.  correct is t3://10.80.4.206:8001

• JMS: How to set the time-out to a JMS queue in the weblogic admin conso

  Hello
  
  
  I need to fix a JMS queue for 1 month expiration date, which means I want messages to be persisted in the queue for 1 month. How I put it to the queue in the weblogic administration console.
  
  Thank you
  Kalapana.

  Go to the queue on the weblogic Admin Console. Select the Exceptions tab. There is an option of substitution of Time-to-live. You can set the length of your message there. This will overrirde life defined by the producer.

• JMS queue

  Hello
  
  I read an xml file and pushed to the JMS queue successfully.
  Now, I need to read it and place it in another location.
  Pls guide me on this.

  You can create a proxy service with JMS as Protocol and transport likewise, Endpoint URI configuration: jms: / /:/ and so on.

  Kind regards!

• Consume a Message from a JMS queue on request

  Hello
  I do a few experiments with BPEL and JMS adapter.
  I know how to configure the JMS adapter to subscribe to a queue and begin a BPEL process, but I am trying to achieve a design that is more similar to the following:
  1 BPEL receives a service Web dial with a payload containing MsgID - it's activity "instantiate".
  2 BPEL called JMS adapter with MsgID
  3 JMS adapter removes the message with the given MsgID and returns it to the BPEL (or reports not found)
  4 BPEL process the message
  I have read the documentation on the JMS request/response adapter, but not what I'm looking for. Someone know how I can get this feature?
  I prefer to do it using the JMS adapter, another option could be a custom Java code that uses the JMS API.
  You can also use a JMS queue is maybe the wrong way to achieve this in which case I could code to store messages in a database and retrieve on demand.
  Robert

  I feel that a DB table would provide better support for your case.

  I'm not aware of an API to receive a message based on its JMSMessageId.
  There is a MessageConsumer.receive (), but this does not select messages based on any filter.

  Maybe I'm totally wrong, in this case, I would be happy to learn from my mistakes.

• How to manually publish the data in a JMS queue

  Hi all
  
  We have a weblogic JMS queue and an OSB acting as a consumer.
  Is it possible to display the results (xml entry) in this queue manually without creating a producer.
  
  TIA,
  Vishal

  Open the console server WL.
  Go to the JMS Module
  Click Queue--> Monitoring--> select the checkbox of the queue and click Show messages--> click on the NEW button... Then, you can send a message to the queue.

• Copy of the JMS queues

  I write Weblogic Integration (WLI) applications. When I deploy these apps I create JMS queues on the server or I get warning messages in the Weblogic console. I have several Weblogic 10.3 servers that I need to deploy these applications WLI too.
  
  I wonder if there is a way I can copy the contents of the xml files that define the queues JMS from one server to another server? What are the files should be copied? I'm trying to find an easier way to create JMS queues. Create queues in the console can get a lot of time if you have a lot of queues to create.
  
  Any help is greatly appreciated!
  
  John

  Hi John,.

  There are several ways to automate the configuration of WebLogic and WebLogic JMS (like all other subsystems WebLogic), can be configured with any of them. Here are a few:

  -Script WLST on-line or off line

  -Program in Java that makes calls to mbean JMX config

  -If the JMS-dest config is absolutely identical, then you can just copy the XML of the JMS module in different areas and then use the console, JMX or WLST to modify the config.xml file to reference it. The module contain config destination, while the config.xml file contains subdeployment, store, and JMS server config.

  When you work with several WebLogic domains, make sure that all domain names are different and all the WebLogic Server names are different (even if the WebLogic servers are in different domains). In addition, in some cases all the JMS server names must be different (even if they are in different domains - apply to the apps feature FAS that use meet cross-domain if I remember correctly).

  Tom

  PS. See also [best practices Configuration JMS | http://download.oracle.com/docs/cd/E15523_01/web.1111/e13738/best_practice.htm#CACJCGHG]

• Dynamic creation of the JMS queues

  Hello
  
  I understand that it is possible to define queues (and subjects) in configuration appropriate application jms.xml file. However, I suppose it is also possible to dynamically create JMS queues (i.e. at run time).
  
  Could someone point me in the right direction for more information on how I can achieve this? I used have a Oracle 10 g and intend to use Oracle AS JMS.
  
  Thank you very much
  
  
  Alistair.

  Hi Alistair,.

  Your options:
  (1) JMX Mbeans [http://download-east.oracle.com/docs/cd/B25221_04/web.1013/b14432/jmxbrowser.htm]
  (2) [http://download.oracle.com/docs/cd/B31017_01/web.1013/b28951/anttasks.htm] ant tasks

• cannot resolve the new jms queue.

  Hi all, I'm new to weblogic. I try with weblogic JMS weblogic example queue, it works very well. Can I send and receive from the queue (tail Original provided for example weblogic called "exampleQueue").
  But when I try to create a new queue (exampleQueue2) and use the source of the example just rename the name of queue, it throws the following exception. Can someone tell me what's going wrong with the queue, I created.
  
  
  
  Running on the local machine of weblogic.
  
  Exception in thread "main" javax.naming.NameNotFoundException: unable to resolve 'weblogic.examples.jms.exampleQueue2 '. Solved "weblogic.examples.jms" [root exception is javax.naming.NameNotFoundException: could not resolve "weblogic.examples.jms.exampleQueue2".] Fixed the "weblogic.examples.jms"]; other name 'exampleQueue2 '.
  at weblogic.rjvm.ResponseImpl.unmarshalReturn(ResponseImpl.java:234)
  at weblogic.rmi.cluster.ClusterableRemoteRef.invoke(ClusterableRemoteRef.java:348)
  at weblogic.rmi.cluster.ClusterableRemoteRef.invoke(ClusterableRemoteRef.java:259)
  at weblogic.jndi.internal.ServerNamingNode_1030_WLStub.lookup (unknown Source)
  at weblogic.jndi.internal.WLContextImpl.lookup(WLContextImpl.java:392)
  at weblogic.jndi.internal.WLContextImpl.lookup(WLContextImpl.java:380)
  at javax.naming.InitialContext.lookup(InitialContext.java:392)
  at examples.jms.queue.QueueSend.init(QueueSend.java:55)
  at examples.jms.queue.QueueSend.main(QueueSend.java:93)
  Caused by: javax.naming.NameNotFoundException: unable to resolve 'weblogic.examples.jms.exampleQueue2 '. "Weblogic.examples.jms" solved
  at weblogic.jndi.internal.BasicNamingNode.newNameNotFoundException(BasicNamingNode.java:1139)
  at weblogic.jndi.internal.BasicNamingNode.lookupHere(BasicNamingNode.java:252)
  at weblogic.jndi.internal.ServerNamingNode.lookupHere(ServerNamingNode.java:182)
  at weblogic.jndi.internal.BasicNamingNode.lookup(BasicNamingNode.java:206)
  at weblogic.jndi.internal.BasicNamingNode.lookup(BasicNamingNode.java:214)
  at weblogic.jndi.internal.BasicNamingNode.lookup(BasicNamingNode.java:214)
  at weblogic.jndi.internal.BasicNamingNode.lookup(BasicNamingNode.java:214)
  at weblogic.jndi.internal.RootNamingNode_WLSkel.invoke (unknown Source)
  at weblogic.rmi.internal.BasicServerRef.invoke(BasicServerRef.java:589)
  at weblogic.rmi.cluster.ClusterableServerRef.invoke(ClusterableServerRef.java:230)
  to weblogic.rmi.internal.BasicServerRef$ 1.run(BasicServerRef.java:477)
  at weblogic.security.acl.internal.AuthenticatedSubject.doAs(AuthenticatedSubject.java:363)
  at weblogic.security.service.SecurityManager.runAs (unknown Source)
  at weblogic.rmi.internal.BasicServerRef.handleRequest(BasicServerRef.java:473)
  at weblogic.rmi.internal.wls.WLSExecuteRequest.run(WLSExecuteRequest.java:118)
  at weblogic.work.ExecuteThread.execute(ExecuteThread.java:201)
  at weblogic.work.ExecuteThread.run(ExecuteThread.java:173)
  
  
  
  Run in a different machine.
  
  Exception in thread "main" javax.naming.NameNotFoundException: Exception in research. : ' weblogic/examples/jms/exampleQueue2' was not found. [Root exception is weblogic.corba.cos.naming.NamingContextAnyPackage.NotFound: IDL:weblogic/corba/cos/naming/NamingContextAny/NotFound:1.0]
  at weblogic.corba.j2ee.naming.Utils.wrapNamingException(Utils.java:65)
  at weblogic.corba.j2ee.naming.ContextImpl.lookup(ContextImpl.java:230)
  at weblogic.corba.j2ee.naming.ContextImpl.lookup(ContextImpl.java:168)
  at javax.naming.InitialContext.lookup(InitialContext.java:351)
  at examples.jms.queue.QueueSend.init(QueueSend.java:55)
  at examples.jms.queue.QueueSend.main(QueueSend.java:93)
  Caused by: weblogic.corba.cos.naming.NamingContextAnyPackage.NotFound: IDL:weblogic/corba/cos/naming/NamingContextAny/NotFound:1.0
  at weblogic.corba.cos.naming.NamingContextAnyPackage.NotFoundHelper.read(NotFoundHelper.java:72)
  at weblogic.corba.cos.naming._NamingContextAnyStub.resolve_any(_NamingContextAnyStub.java:87)
  at weblogic.corba.j2ee.naming.ContextImpl.lookup(ContextImpl.java:208)
  ... 4 more
  
  
  Thanks in advance.

  Happy to help :)

  The jndi-local name hides under the section advanced in the console Services/weblogic/JMS Modules / [your Module] / General

  I hope that answers your question, mate!
  See you soon,.
  -Adrian

• How to configure a proxy server to listen to a jms queue

  I have to work the next senario.
  
  
  
  (1) service proxy/business will push the message to a jms queue1
  
  (2) another proxy will query this message from this queue1.
  
  
  
  can any body help how to achieve this.
  
  
  
  Expecting an explanation for each of them... : |

  Before I explain how to do this, allow me to clarify the purpose of a business service and a proxy service:

  -Service business is the representation of Bus Service from a service provider - that is a service that you call the BUS
  -A proxy service is exposed to your good service - service of Bus Service that is a service hosted ON the bus

  So, to place a message in a queue FOR THE bus (your scenario 1), you will need create a business service (need to be e-mail type and use the common JMS transport). You will also need to create the JMS resource (queue/topic plant and connection yourself, because these will be generally on another computer by the service bus). This service can not be called directly by consumers of services - you will need for it from the front with a service proxy to do this. This proxy service could, if you choose, expose this business using a different message format and/or a different protocol if you wish.

  To search for messages in a queue, you need to set a proxy service (also on the type of messaging and the use of the JMS transport). In this case, given that the proxy service is hosted on the Service Bus the JMS resources are created for you (unless of course the queue is remote).

  Please post here if you have any other questions.

  Thank you

  Chris

• A producer with many consumers

  Hi all I try to use the architecture of producer-consumer in my program.  My producer loop is a loop of the acquisition of analog input.  I want to enqueue data acquired for 3 separate consumers.  The first loop of consumer would write the data to a file, the second consumer send the data to the façade, and the third consumer would send analog output based on the data. It seems to me that if any consumer data, consumers would have nothing to dequeue.  I want that they get the same data at the same time.  What I really need to create 3 queues and enqueue data to 3 separate queues?  Is there a better way?  Thank you!

  Yes.  That's what you need to do.  Maybe someone else knows another exotic way to do this, but I think it would be too complicated.

  You can store the queue references in a table.  Wrap the enqueue function in a loop For that takes the array of the queue a tunnel of autoindexing.

• Message-Driven beans and the order of the messages in the JMS queues.

  Hi all

  We use Weblogic 10.3.6 and we have a cluster with 2 JMS servers. In our project, it is important to process messages in the order when they arrive in the queues.

  Our question is simple enough, the fact that Message-Driven Beans (of the sort that take up messages in parallel) follow the order of the messages? Or do we need to configure something to do this.

  Thank you!

  According to the oracle documentation:

  With the help of unit-of-Order with Destinations spread

  As already mentioned in the Message of treatment according to the specification of JMS, Service of Message in Java specifications (to http://www.oracle.com/technetwork/java/jms/index.html ) doesn't guarantee no message ordered delivery when applications use distributed queues. WebLogic JMS redirects messages with the same disorder unit and have a target distributed to the same distributed destination member. The Member is chosen by unit of the order of the destination configuration:

  • By using the Service path
  • The hash-based routing using

  You can also

  If you distribute, you can use control unit andmax-beans-in-free-pool:

  http://docs.Oracle.com/CD/E23943_01/Web.1111/e13814/mdbtuning.htm#BABBEFCA

  More information here:

  Using Message unit-of-Order - 11g Release 1 (10.3.6)

  Tuning Message-Driven Beans - 11g Release 1 (10.3.6)

  WebLogic Server (WLS) JMS mapping control unit works with uniform distribution Destinations (Doc ID 1310795.1)

  Best regards

  Luz