JMS Messages, refusing to participate in JTA transactions

Similar Questions

• JMS provider does not participate in the user JTA Transaction

  Hello
  
  I use a JTA on WebLogic 8.1 user Transaction. Under the operation, I have two datasources viz SQL Server Database, and Tibco EMS. The database is involved in the distributed transaction, while this isn't the JMS provider.
  
  I set up the XAQueueConnectionFactory in the foreign JMS on WebLogic servers. I use this factory to create the QueueConnection, then the QueueSession and the QueueSender. I use no transactional QueueSession, so, he participated in the JTA transaction. However, I have noticed that the message send operation outside the transaction. Ideally, the message should be sent only when the JTA transaction is committed, but the message is sent immediately after you call the code, and I see the message even if the JTA transaction is rollbacked.
  
  I also tried to use the XAQueueConnection and XAQueueSession but no luck. Can someone please?
  
  Published by: user10749653 on December 30, 2008 16:25

  Please post an excerpt of your code create session and send messages and the descriptor. I wonder if call you commit (you say with transaction) somewhere and if you declare the factory connections such as resource-ref. In the case where you did not declare the CF as a resource, and not call validation, I expect that your messages are not visible to the receiver because the resource would not be allowed to enroll in the transaction. Proper enlistment is guaranteed when you use a XA(Queue|) Topic:) ConnectionFactory and resource-ref it. The transactional and ACK session settings are ignored in global transactions.

• HOWTO: query inflight JTA transactions in the store persistent programmatically

  Hello
  We are trying to work on a way, in a non-clustered, work, environment if there are transactions waiting/inflight JTA in the persistent store when the server is not running. (With a running server, it would be easy, just ask the MBeans JTA).
  
  The reason for which we need is: at least some automated directed data JTA power managed server upgrade scripts and custom. If the operator stopped the server, perhaps with Force Shutdown or simply by killing the process. And now wants to restart:
  for an Instance of WLS with inflight JTA transactions, the server will attempt to recover the in-flight transactions, which could take a long time and be understood by the operator as a blocking of the server.
  At which point, the operator is likely to do exactly the wrong thing: recreating the domain of the server, including the persistent store and therefore lose all flight operations.
  
  So ideally, we would have either a java, wlst or based on a shell-script how to query the persistent store to find out if there are flight operations. We can then warn the operator, or manually move the file somewhere else.
  
  We thought of two ways to do:
  
  (a) use weblogic.store.Admin to dump the store as xml. The problem is, we don't know what parts there are empty, and what strings to search by program to find flight operations.
  
  (b) enable DebugJTARecovery on the server and restart it as a test, and then search your messages for recovery. Tedious and complicated.
  
  (c) there must be a method of MBean undocumented than the administration Console used to allow migration to a persistent store. Any tips?
  
  Some information resources that we consulted that have not delivered the answers
  
  http://download.Oracle.com/docs/CD/E12840_01/WLS/docs103/JTA/trxman.html#wp1043084
  
  Transactions For recovery has Failed Non-Clustered Server basically said to copy the file, recreate the server and hope
  
  http://download.Oracle.com/docs/CD/E13222_01/WLS/docs92/config_wls/store.html#wp1149755
  
  Description of the weblogic.store.Admin utility command-line options.
  
  There was formerly a utility in the WLS 8.1 days, which would dump an ascii representation of the tlog file. It does not seem to have been replaced.
  
  Thank you, Richard

  WLS administration console uses the runtime mbeans to find pending JTA transactions, so that won't be useful to you if you want this info in offline mode. When the console migrates, it does by using the MigratableServiceCoordinatorRuntimeMBean, which encapsulates the details of the migration of jta.

• How to send a JMS Message to a process of BPM

  Hi all
  
  I have small question regarding the sending of JMS Message of a bpm process. Is it possible to send a bpm process JMS messages to another bpm process.
  
  I have a scenario in which I need to send a JMS message to a queue, where another process is listening on this queue, and upon receipt of the message in the queue that is created for the process instance.
  
  I know how to listen to the JMS message on the queue, but I did not how to send a message to a process JMS.
  
  Also can I create processes by sending Notification to the process instead of a JMS message. But the creative process isn't a subprocess i.e. a declaration can be addressed through different processes.
  
  
  Any information or the example in this respect would be useful.
  
  Thanks in advance
  
  Published by: user9945154 on April 22, 2009 19:46

  Hello
  Daniel already told you how to send a JMS message.

  To send messages between different processes, you can use the Notification component:
  http://download.Oracle.com/docs/CD/E13154_01/BPM/docs65/standard_components/Fuego/lib/notification/Notification_component.html

  To create an instance of another process, you can use the ProcessInstance:
  http://download.Oracle.com/docs/CD/E13154_01/BPM/docs65/standard_components/Fuego/lib/ProcessInstance/ProcessInstance_component.html

  If you want to create an instance of another process, I recommend you ProcessInstance component because the creation is done in the same transaction. That has advantages:
  1 - is much faster!
  2. it is performed in the same transaction. Thus, you will be sure that the instance has been created.
  3. you don't have to wait until the arrival of the notification. (Sometimes, this reduces the interprocess synchronization)

  Hope this helps,
  Ariel

• A JMS message is not a property of the unity of the order and a unit of work property

  
  I received this message on my side Client of JMS:

  weblogic.jms.common.JMSException : A JMS message is not a property of the unity of the order and a unit of ownership of the work

  I put only the unit of work properties in what follows.  Don't know why he complains that I put together.

  Joe

  ***************************************************

  message.setStringProperty ("JMS_BEA_UnitOfWork", rMes.getPid ());

  message.setIntProperty ("JMS_BEA_UnitOfWorkSequenceNumber", rMes.getSequence ());

  message.setBooleanProperty ("JMS_BEA_IsUnitOfWorkEnd", rMes.isEnd ());

  } catch (Exception e) {}

  System.out.println ("Unit of work" + e.getMessage ());

  }

  queueSender.send (message, DeliveryMode.PERSISTENT, 7, 0);

  I think I found the answer.  While I was watching Oracle Oracle guru Jeff West of Youtube video, he suddenly appeared to me that I missed the series WL classes JMS.

  Import weblogic.jms.extensions.WLConnection;

  Import weblogic.jms.extensions.WLDestination;

  Import weblogic.jms.extensions.WLQueueSession;

  Import weblogic.jms.extensions.WLMessageFactory;

  Import weblogic.jms.extensions.WLMessageProducer;

  Import weblogic.jms.extensions.WLQueueSession;

  This is the code that actually works!  I changed to PUA, however, based on the characteristics of our company. Now the Weird message of "properties have PUA both UOW" disappeared!

  Joe

  *****************

  package test.viant.edi.translator.messaging.processor.images.impl;

  import java.io.BufferedReader;
  import java.io.FileInputStream;
  import java.io.IOException;
  import java.io.InputStreamReader;
  import java.util.ArrayDeque;
  import java.util.Hashtable;
  to import java.util.Iterator;

  Import javax.jms.DeliveryMode;
  Import javax.jms.JMSException;
  Import javax.jms.Queue;
  Import javax.jms.QueueConnection;
  Import javax.jms.QueueConnectionFactory;
  Import javax.jms.QueueSender;
  Import javax.jms.QueueSession;
  Import javax.jms.Session;
  to import javax.jms.TextMessage;
  to import javax.naming.Context;
  Import javax.naming.InitialContext;
  Import javax.naming.NamingException;

  Import weblogic.jms.extensions.WLConnection;
  Import weblogic.jms.extensions.WLDestination;
  Import weblogic.jms.extensions.WLQueueSession;
  Import weblogic.jms.extensions.WLMessageFactory;
  Import weblogic.jms.extensions.WLMessageProducer;
  Import weblogic.jms.extensions.WLQueueSession;

  public class UOOProducer {}
  private static string = "-1" current group
  private static int currentSeq = 1;

  Public Shared Sub main (String [] args) {}

  Dim queueName = "jms/MsgProcSvc/gisInboundQueue";
  String queueConnectionFactoryName = "jms/MsgProcSvc/jmsMsgProcConnectionFactory";
  Context jndiContext = null;
  Factory Factory = null;
  WLConnection queueConnection = null;
  WLQueueSession queueSession = null;
  Queue queue = null;
  WLMessageProducer queueSender = null;
  TextMessage message = null;
   
  / * Set the environment for a connection to the OC4J instance * /.
  Hashtable env = new Hashtable();
  env.put (Context.INITIAL_CONTEXT_FACTORY,
  "weblogic.jndi.WLInitialContextFactory");
  env.put ("java.naming.rmi.security.manager", "Yes");
  env.put (Context.PROVIDER_URL, "t3: / / localhost:5557, localhost:5558" "");
  /*
  The value of the context object. * Search for the queue connection factory. *
  * Search for the JMS Destination.
  */
  try {}
  jndiContext = new InitialContext (env);
  Factory = jndiContext (Factory)
  . Lookup (queueConnectionFactoryName);
  queue = jndiContext.lookup (queueName) (tail);
  } catch (NamingException e) {}
  System.out.println ("JNDI lookup failed:" + try ());
  System.Exit (1);
  }
  /*
  To create the connection. * Create connection session. * Create
  * sender. To create text message. To send messages. Send some out of text
  the message at the end of the text messages. * Close the connection.
  */

  try {}
  queueConnection (WLConnection) = queueConnectionFactory.createQueueConnection ();
  queueSession (WLQueueSession) = queueConnection.createQueueSession (false,
  Session.AUTO_ACKNOWLEDGE);
  queueSender (WLMessageProducer) = queueSession.createSender (tail);
  message = queueSession.createTextMessage ();
    
    
  try {}
  Open the file
  FileInputStream fstream = new FileInputStream("U:\\114157\\testFile1.txt");
  BufferedReader br is new BufferedReader (new InputStreamReader (fstream));.

  String strLine;
  ArrayDeque messageDeque = null;
     
  Read the file line by line
  While ((strLine = br.readLine ())! = null) {}
  Print content on the console
  System.out.println (strLine);
  String pidOfLine = getpid(2) (strLine);
  EDIMessage em = new EDIMessage();
      
  If (! pidOfLine.Equals (currentGroup)) //If this is a new group or the beginning of the message
  {
       
  If (messageDeque! = null &! messageDeque.isEmpty ()) {}
  EM = (EDIMessage) messageDeque.removeLast ();
  em.setEnd (true);
  messageDeque.addLast (em);
        
  EDIMessage AFFECTS = null;
  The message group is now ready.
  for (Iterator itr = messageDeque.iterator (); itr.hasNext ();)  {
  AFFECTS = (EDIMessage) itr.next ();
  try {}
  message.setText (em.getMessage ());
  message.setStringProperty ("JMS_BEA_UnitOfOrder", rMes.getPid ());
  * message. SetStringProperty ("JMS_BEA_UnitOfWork", rMes.getPid ());
  message.setIntProperty ("JMS_BEA_UnitOfWorkSequenceNumber", rMes.getSequence ());
  message.setBooleanProperty ("JMS_BEA_IsUnitOfWorkEnd", rMes.isEnd ());
  String of PUA = message.getStringProperty ("JMS_BEA_UnitOfOrder");
  String uow = message.getStringProperty ("JMS_BEA_UnitOfWork");
  System.out.println ("PUA:" + PUA);
  System.out.println ("uow:" + uow) ;*/
          
  } catch (Exception e) {}
  System.out.println ("Unit of work" + e.getMessage ());
  }
  System.out.println ("before sending the message:" + AFFECTS + "\n");
  queueSender.send (message);
          
  }

  }
  current group = pidOfLine;
  currentSeq = 1;
  messageDeque = new ArrayDeque();
       
       
  }
      
  What is the new nest or not, fill these values
  em.setPid (pidOfLine);
  em.setSequence (currentSeq);
  em.setEnd (false);
  em.setMessage (strLine);
  messageDeque.addLast (em);
      
         
      
  }

  Close the input stream
  Br. Close();
  } catch (IOException ioe) {}
  System.out.println (ioe.getMessage ());
  }
    
    
  } catch (Throwable e) {}
  e.printStackTrace ();
  System.out.println ("Exception occurred:" + e.getMessage ());
  } {Finally
  If (queueConnection! = null) {}
  try {}
  queueConnection.close ();
  } catch (JMSException e) {}
  System.out.println ("error in closing:" + try ());
  }
  }
  }
  }

  private static String getpid(2) (String sampleString) {}
  int start = nthIndexOf (sampleString, "|", 4);
   
  System.out.println ("start =" + start);
  int end = nthIndexOf (sampleString, "|", 5);
  System.out.println ("end =" + end);
  Return sampleString.substring (start + 1, end);
  }

  public static int nthIndexOf (final String string, final string token
  final int index) {}
  int j = 0;

  for (int i = 0; i)< index;="" i++)="">
  j = string.indexOf (token, j + 1);
  If (j == - 1).
  break;
  }

  return j;
  }

  }

• JMS message filtering

  Hello

  can we filter JMS message form

  
  

  
  

  Thank you

  I could not understand the question, but according to my knowledge, selector of JMS messages is static configuration and must have the exact value at the time of the design itself which is the way it currently works. What you're looking for is "way to assess the selection criteria based on the expression at the time of execution". I don't think that he is currently supported.

  If we descend into thinking more than why this behavior, then we can say that if we want to execute logic, so we have to instantiate who hold the variables and evaluate expressions of a thread, but Message selector is nothing, but subscription so property whenever a Subscriber is stored in the JMS server he hears message based on it and when something specific Vienna then only he initiated a thread for subscriber process further.

  What will be needed in your case, it's this Subscriber subscribe all messages and will initiate the thread and then reject the message based on the logic of the selector within the scope of the processing thread. I don't think it will be good idea because it will instantiate many unnecessary wires in a business solution. This will be equivalent to an if-else in the pipeline early condition to reject unwanted messages. The whole idea of having Message selector must give this responsibility to the subscription instead of the Subscriber. I don't think that selector messages JMS should work this way.

  I hope that I have understood the question correctly and especially the help of details mentioned.

  Kind regards

  Ankit

• Reading at the OAG JMS message

  Hello

  I'm trying to read a message of IBM MQ and validate againist a schmea. I am able to read IBM MQ, but I get the error message when posting as below.

  30/Oct/2013:20:46:07.120 [230] fault nested ERROR: no content HTTP in the message:

  java.io.IOException: no content HTTP in the message

  at com.vordel.mime.XMLBody.locate(XMLBody.java:99)

  at com.vordel.mime.XMLBody.getDocument(XMLBody.java:86)

  at com.vordel.circuit.schema.SchemaValidationProcessor.invoke(SchemaValidationProcessor.java:205)

  at com.vordel.circuit.InvocationEngine.invokeFilter(InvocationEngine.java:160)

  at com.vordel.circuit.InvocationEngine.invokeCircuit(InvocationEngine.java:52)

  at com.vordel.circuit.InvocationEngine.processMessage(InvocationEngine.java:241)

  at com.vordel.dwe.jms.JMSConsumer.processMessage(JMSConsumer.java:170)

  at com.vordel.dwe.jms.JMSConsumer.run(JMSConsumer.java:321)

  at java.lang.Thread.run(Thread.java:662)

  Kind regards

  Ganesh

  
  

  Hello Stefen,

  Thanks a lot, with the input data (${jms.message.getText ()} I am able to read XML. JMS now validating schema works fine. reterive the filter element also works very well.)

  you saved my day!

  Kind regards

  Ganesh

• Retrieving ID of the JMS Message using Java

  Hello
  
  I built a sequence flow which is JMS Producer (BPEl)-> Consumer (Bpel) JMS-> composite A Bpel, inserting database. Now, I deliberately blamed the bpel instance. now, I want to enter the instance bpelcomposite faulted consumer id which I was able to do, but also to retrieve the message id jms I have been unsuccessful.
  I imported the javax.jms.Message package and my code is as follows
  / public class FaultHandlingPOC implements IFaultRecoveryJavaClass {}
  
  {} public void handleRetrySuccess (IFaultRecoveryContext ctx)
  
  System.out.println ("this is for the success of the new attempt");
  
  handleFault (ctx);
  
  }
  public String handleFault (IFaultRecoveryContext ctx) {}
  BPELFaultRecoveryContextImpl bpelCtx = (BPELFaultRecoveryContextImpl) ctx;
  Message m = ctx (Message);
  System.out.println ("Instance Composite:" + bpelCtx.getCompositeInstanceId ());
  
  try {}
  System.out.println ("ID of Message JMS" + m.getJMSMessageID ());
  } catch (JMSException e) {}
  System.out.println ("insert failed");
  }
  
  return to "Rise again";
  }
  
  The error generated is class Cast Exception even if I am able to retrieve the Bpel composite instance id
  
  Help, please.

  You can not thrown another IFaultRecoveryContext thing, it's an Interface and it does not do anything:

  public interface IFaultRecoveryContext
  {

  public abstract String getIndex (int i);

  public abstract card getProperties();

  public abstract String getActionId();

  public abstract String getPolicyId();

  public abstract String getActivityType();

  public abstract String getActivityId();

  public abstract String getActivityName();

  public abstract String getWsdlLocation();

  public abstract String getPartnerLinkName();

  public abstract QName getPortType();

  public abstract String getCorrelationId();

  public abstract BPELFault getFault();

  public abstract BPELProcessId getProcessId();

  public abstract String getStatus();

  public abstract void setStatus (String s);

  public abstract String setTitle (String s);

  public abstract String getTitle();

  public abstract int getPriority();

  public abstract setPriority (int i) Sub;

  public abstract getInstanceId() long;

  public abstract Locator getLocator();

  public abstract void addAuditTrailEntry (String s, object obj);

  public abstract void addAuditTrailEntry (String s);

  public abstract void addAuditTrailEntry (Throwable throwable);

  public abstract Object getVariableData (String s)
  throw BPELFault;

  public abstract Object getVariableData (String s, String s1)
  throw BPELFault;

  public abstract Object getVariableData (String s, String s1, String s2)
  throw BPELFault;

  public abstract void setVariableData (String s, Object obj)
  throw BPELFault;

  public abstract void setVariableData (String s, String s1, Object obj)
  throw BPELFault;

  public abstract void setVariableData (String s, String s1, String s2, object obj)
  throw BPELFault;
  }

• Treatment of JMS messages in order one after another

  It's my use case that I wan to implement in OSB.
  
  1. I have a queue that will receive the messages in the huge number of a single sender.
  2. I have a proxy that will read each message and process the message and send it out.
  
  In step 1, I want each message to be read in order and at step 2 end run, then I want to read the next message in the queue.
  
  I need to give an acknowledgement to JMS message processing is complete and it can make the next available message to the proxy.
  
  What is the best option to implement this use case?
  
  Concerning

  The WebLogic jms to order unit is the best approach for this.
  http://download.Oracle.com/docs/CD/E12840_01/WLS/docs103/JMS/uoo.html

• JTA transaction is not present or the operation is not in Active state

  Hello
  
  I am trying to execute an asynchronous bpel process. the bpel process has 5 calls to OSB and takes about 100 seconds for completion. The OSB in the BPEL calls take 90 seconds to complete. At the end of the BPEL process, after completion, I get the following error:
  
  [2010-07-22 01:56:44] BPEL process instance completed "1220007"
  [2010-07-22 01:56:44] There is a system exception during execution of the BPEL instance, the reason is "JTA transaction is not present or the operation is not in Active state. The current JTA transaction is not present or is not in Active state, when processing activity or instance '1 220 007 '. The reason is the performance of this '1220007' for instance 'BPELProcess1' process is supposed to be in a jta transaction, but the transaction is not present or in Active state, please enable debugging application server transaction logs for more information... Please see your administrator about this error. ". Please check the log file of errors for more infromation. Please try to use bpel error handlers to catch errors in your bpel process. If it is an exception system, please report it to your system administrator. Administrator could perform a manual recovery of the last non-idempotent or point of dehydration activity instance.
  
  We do not want to increase the properties of transaction-timeout in the Transaction Server - manager .xml or the orion-ejb - jar.xml, since we have other projects with synchronous process running on the same server.
  
  Can someone please suggest a solution to this problem Besides not to increase the transaction time-out?

  It's because our BPEL process took more time allotted for JTA transaction.

  Check transaction timeout in j2ee/config/transaction-manager.xml.

  If you use the idempotent or control point (all that forces of dehydration) before the time specified above, you get the error.

  While BPEL actually continues execution, he cannot commit to store of dehydration after cancellation timeout and forces.

  -Sridhar

• JMS messages not go back

  Hi all

  I now have a case where I dequeue messages to a JMS queue and call several downstream services. The problem is that I use redelivery options in my bpel process incase of mistakes downstream services and restitution does not occur. From the console 'em, for the wrong instance id, I need manually restore the fault and automatic playback does not occur.

  Please help me.

  Thank you

  Hello

  You didn't mention what version of Oracle SOA do you use? Also please let us know if you are using an XA connection for the JMS adapter.

  Normally, you experience this problem when ' bpel.config.oneWayDeliveryPolicy ' is set to 'async.persist' in the file composite.xml.   Please check your composite.xml and change the value to ' sync ' (rebuild/modify your existing configuration plans).

  Please indicate whether the response is useful.

• JMS Message tracking

  Hi all

  We use Weblogc 10.3.6 using JMS queues.

  We're going into production soon, qe want to trigger an alert message if we have not received any messages in our queues for example 30 minutes or 1 hour?

  How can I do? I tried to use WLDF but I couldn't find a way to solve this problem.

  Thank you very much!!!

  Hello

  You can write a line of WLST script to browse or get the MBean of UDQ and monitor for any message that lands on it.

  Once which is reached, you can present sleep for 5 min or 10 min or what is your nfr.

  HTH

  Sri

• The command cluster JMS messages.

  Hi all

  We use Weblogic 10.3.6 and we have a cluster with 2 JMS servers.

  In our project, it is important to control the message that we receive...

  Does anyone know how to order messages in a cluster with multiple JMS servers?

  Thank you very much!

  Chiwatel,

  You can use the feature "unit-of-Order.  It will consolidate the messages into a single unit with regard to the processing order. He

  requires that all messages from this unit be treated sequentially in the order that they were created.

  For more information, see:

  http://docs.Oracle.com/CD/E14571_01/Web.1111/e13727/uoo.htm#JMSPG389

• WebLogic JMS: Messages in the queue are not displayed correctly

  Hello
  
  I use business OSB (courier, query type = type of text and the answer = none) and I publish the message encoded in URL next to a JMS queue:
  
  * %3 C % 3Fxml % 20version % 3D % 221 *.
  
  
  then, when I discovered the message in the queue by using the Weblogic console it is shown as:
  
  * 00000000: 2533 4325 3346 786 d 6 c 25 3230 7665 7273 %3 C % 3Fxml % 20vers *.
  * 00000010: 696f 3344 2532 3231 2532 3225 2e30 6e25 *.
  
  Why these numbers come from the message when it is published to the queue.
  
  Kindly help me to understand this and how to solve the same.
  
  Thank you
  Kalpana.

  The numbers are just an artifact of the way in which the message is displayed by the console. They are a binary representation of the data from your channel.

  More precisely, it looks like the view you are using shows a binary representation, in hexadecimal, on the left side and an ASCII representation on the right side.

  for example

  "72" is ASCII hex for the 'r '.
  '73' is ASCII hex for "s".

  and, on the next line

  '69' is ASCII hex for 'i '.

  HTH,

  Tom

  Published by: Tom B on April 25, 2013 17:59

• About JMS transfers the JMS Messages

  Hello
  
  In my organization, we have implemented weblogic 10.2.5, suddenly our JMS topics stopped before messages to subscribers, no idea?
  
  your help is very appreciated.
  
  Mansoor
  
  Kind regards.

  The problem might be a network, application, client or server problem. Your primary investigative tool includes your server log (look for the errors & warnings), thread dumps client & server (glance for blocked threads) and all the exceptions that can be thrown to your customers.

  A few questions that might help to refine the question:

  Several areas are involved?

  Do you use distributed topics?

  What is the maximum size of your messages?

  HTH,

  Tom