jms - HornetQ 2.2.5 Embeded Example Exception -

-

I'm new to Hornetk and I'm testing Singtekyu examples. Example I'm getting an exception when embedded example. Java (resides in: hornetq-2.2.5. Last \ example \ core \ embedded \ src \ org \ hornetq \ core \ example). I made some changes in that example and got the exception. When I made the change, I sent the process and consumption process to the loop of 1 00,000 currency. The code is: 

  System.out.println ("Creator:"); System.out.println ("Start:" + New Date ()); For (Int i = 0; i & lt; 100000; i ++) {message.putStringProperty (Prop name, "Message:" + i); Producer.send (message); } System.out.println ("End date:" + New date ()); // Step 7. Make Message Consumer and Start the Connection Client Consumer Message Consumer = session.createConsumer (queueName); Session.start (); // Step 8. Get Message Println ("Consumer:"); System.out.println ("Start:" + New Date ()); For (int i = 0; i <100000; i ++) {client message received = message consumer Receive (); Println (messageReceived.getStringProperty (propName)); } System.out.println ("End date:" + New date ());   
 The manufacturer works well, and the client gives me an exception after reading 18k or 13k msges. Stack trace:  
  [java] message: 18384 [Java] Sep 2 ,, 2011 11:15:29 org.hornetq.core.logging.impl.JULLogDelegate information [Java] information : HornetQ Server Version 2.2.5.Final (HQ_2_2_5_FINAL_AS7, 121) [588e32ee-d493-11e0-b759-0026b6a94d9b] Closed [java] HornetQException [errorCode = 102 Message = Consumer Closed] [Java] org.hornetq On .core On client.impl.ClientConsumerImpl.checkClosed (C lientConsumerImpl.java:811) org.hornetq.core.client.impl.ClientConsumerImpl.receive (clien tConsumerImpl.java:163) [Java] [Java] on org.hornetq.core. client.impl.ClientConsumerImpl.receive (clien tConsumerImpl.java:364) [Java] on org.hornetq.core.example.EmbeddedExample.main (EmbeddedExample Java: 107) [java] Java Result: -1 BUILD failed C: \ hornetq -2.2.5.Final \ example \ core \ embedded \ build.xml: 40 :? EmbeddedExample   
 How do I overcome this exception   
 
 
 example Only VM will start with 50 M, and on your example you will not be enough for 50 M, after the end of the S 100K message.  
 do I have here is not a change, but I can run instances with the 100K messages provide more storage at Bildkod.  
 Besides, you were getting some exceptions before interrupting the communication and made to close the session. Besides, messaging systems are asynchronous, therefore I Offer to change your sending block to:  
 for  (int i = 0; i & lt; 100000; i ++) {message = sesison.createMessage (true) ); // Send message to it. Input stringproperty (Prop Name, "Message:" + i); Producer.send (message); }   
 And you should also have an ACK on the consumer. Otherwise the message will still be in memory.  
 An intentional example was to show how to embed Hornets. Other uses such as decking and other examples for production.  
 for  (int i = 0; i & lt; 100000; i ++) {client message received = message consumer. Receive (); MessageReceived.acknowledge (); Println (messageReceived.getStringProperty (propName)); }

Comments

Post a Comment

Popular posts from this blog

mysql - BLOB/TEXT column 'value' used in key specification without a key length -

-
I have developed an extension which works up to 1.6 on Magren (I'm trying Enterprise Edition, And I think the community is the same problem, because it is the same code). In my install script, I see the $ installer-> gt; CreateEntityTables ($ this- & gt; getTable ('alphanum / info')); The installation is done until it is not in the _text unit table. It crashed there! It turns out that when I log in to SQL and run it via PHPmyadmin, then this error is: Blob / Text column 'value' is used without the key 'key' . I saw the code there, and this is what is trying to create an index on the value column: -> addIndex ($ this- & gt; getIdxName ($ eavTableName, array ( 'attribute_id array (' attribute_id ',' value ')) - & gt; addIndex ($ this- & gt; getIdxName ($ eavTableName, array (' entity_type_id ' , 'Value')), array ('entity_type_id', 'value')) If there is no if statement is n...
Read more

c# - Using Vici cool Storage with monodroid -

-
Oh, for the moment I am not sure how it is officially supported, but for the success of the people Using Monodroid Vic Cool Storage I am able to leave and compile assemblies in my project, but while trying to use some classes, the errors of time have to be gathered. Especially when trying to connect like the example for Mono Touch string dbName = path. Cobain (environment. Gatefolder path (environment specialfolder personal), "mydb.db3"); // The following line will be called coolestation, where is the database, // to make it if it does not exist, and call a delegate that creates the necessary tables (only when the database file was newly created //) CSConfig.SetDB (DbName, true, () => {CSDatabase.ExecuteNonQuery ("Subscriber Integer Primary Key Attribute, Name Text (50) No, Number, Date First Text (30)");); There is no difference when I try to use the methods of CSConfig and when I cscfif If I try to pass 3 aggregates to STDB (3) then I get the invalid ...
Read more

python - referencing a variable in another function? -

-
I am an experienced TCL developer and write my own processes to help myself. I call it a proc i callVar, print out the value of the variable in a certain format, so I know that it is variable and what is the value "set foo 1; putVar foo" result 'foo = "1" I want to do the same thing in Python, but I can not find the answer :( In TCL I use the up command because when I pass the name of the variable, then I can see the value at the top. . I understand that an advanced light in the dragon There is no mechanism of r, but with its introspection capability, I would think that this is something trivial, but I am not getting the answer anywhere. It seems that this should work: and expanded: def foo (): y = "Hello World" printwor ("y") foo () y = "Hello World " You can, but you should not do so if your code is correct If is needed , then there is something wrong with your design, and you should probably use the dictionar...
Read more