jms - Cannot create ActiveMQ queue or send a message using java -

-

i'm new activemq. i'm running activemq server on windows using default settings on local machine. i've tried create simple queue test sending message.

public class foo {      public static void main(string[] args) {         new foo().send();     }      public void send(){             try {             activemqconnectionfactory connectionfactory = new activemqconnectionfactory("vm://localhost:61616");             connection connection = connectionfactory.createconnection();             connection.start();              session session = connection.createsession(false, session.auto_acknowledge);             destination destination = session.createqueue("testqueue");             messageproducer producer = session.createproducer(destination);             producer.setdeliverymode(deliverymode.non_persistent);              textmessage message = session.createtextmessage("message123");             producer.send(message);              session.close();             connection.close();          } catch (jmsexception ex) {             logger.getlogger(foo.class.getname()).log(level.severe, null, ex);         }     }     }

this code doesn't seem when try check logging on activemq admin page , check queue. (localhost:8161/admin/queues.jsp) queue not created. tried creating queue manually admin page , message not sent queue though queue created.

when test server using commands activemq producer , activemq consumer queue created , messages passed queue , read queue. i'm there nothing wrong server.

when run code terminal output

warn | memory usage broker (1024mb) more maximum available jvm: 887 mb - resetting 70% of maximum available: 621 mb  info | using persistence adapter: kahadbpersistenceadapter[c:\users\prashan\desktop\test\activemq-data\localhost\kahadb]  info | jmx consoles can connect service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi  info | kahadb version 6  info | recovering journal @1:3712  info | recovery replayed 1 operations journal in 0.01 seconds.  info | pliststore:[c:\users\prashan\desktop\test\activemq-data\localhost\tmp_storage] started  info | apache activemq 5.13.2 (localhost, id:capsule-5179-1461559222267-0:1) starting  info | apache activemq 5.13.2 (localhost, id:capsule-5179-1461559222267-0:1) started  info | or more information please see: http://activemq.apache.org  warn | store limit 102400 mb (current store usage 0 mb). data directory: c:\users\prashan\desktop\test\activemq-data\localhost\kahadb has 6947 mb of usable space. - resetting maximum available disk space: 6947 mb  warn | temporary store limit 51200 mb (current store usage 0 mb). data directory: c:\users\prashan\desktop\test\activemq-data\localhost\tmp_storage has 6947 mb of usable space. - resetting maximum available disk space: 6947 mb  info | connector vm://localhost started  info | connector vm://localhost stopped  info | apache activemq 5.13.2 (localhost, id:capsule-5179-1461559222267-0:1) shutting down  info | pliststore:[c:\users\prashan\desktop\test\activemq-data\localhost\tmp_storage] stopped  info | stopping async queue tasks  info | stopping async topic tasks  info | stopped kahadb  info | apache activemq 5.13.2 (localhost, id:capsule-5179-1461559222267-0:1) uptime 1.918 seconds  info | apache activemq 5.13.2 (localhost, id:capsule-5179-1461559222267-0:1) shutdown

you creating embedded broker , message sent there. should connect local machine broker by: tcp://localhost:61616" rather vm://....


Comments

Post a Comment

Popular posts from this blog

javascript - How to get current YouTube IDs via iMacros? -

-
i want viewed youtube video id , save csv via imacros, gets nothing. here js code: var videoid; videoid ="code:"; videoid +="url goto=https://www.youtube.com/watch?v=dbnywxdz_pa"+"\n"; videoid +="add !extract {{!urlcurrent}}"+"\n"; videoid +="set !var1 eval(\"var s=\"{{!urlcurrent}}\"; s.match((?<=watch\\?v=|/videos/|embed\\/)[^#\\&\\?]*);s[0]; \")"+"\n"; videoid +="add !extract {{!var1}}"+"\n"; videoid +="saveas type=extract folder=* file=url.csv"+"\n"; try this: var videoid = "url goto=https://www.youtube.com/watch?v=dbnywxdz_pa" + "\n"; videoid += "set !extract {{!urlcurrent}}" + "\n"; videoid += 'set !extract eval("\'{{!extract}}\'.match(/v=(.{11})/)[1];")' + "\n"; videoid += "saveas type=extract folder=* file=url.csv" + "\n"; iimplay
Read more

c# - Maintaining a program folder in program files out of date? -

-
for program i'm writing in vs c# wpf need store user related information on user's computer. far knew has been done creating folder in c:\program files , adding whatever program related info folder in subfolders or whatever. after doing browsing came across lot of people saying method out of date because access may denied create folder there, works administrative accounts, etc.. 1 site suggested saving c:\users\username\appdata\roaming or c:\users\username\appdata\local. question best , date method saving program data users computer? also take @ msdn article . it uwp apps have general idea put if developing wpf app. you may need these folders: environment.specialfolder.applicationdata environment.specialfolder.localapplicationdata environment.specialfolder.commonapplicationdata
Read more

emulation - Android map show my location didn't work -

-
i have been struggle current location in google map, tried official map demo, not working also. shows getmylocation button on upper right, didn't show blue dot on map current location. here code , i'm using emulator target api 23, guess may emulator's problem since code download directly github. advice appreciated. [screenshot][1] package com.example.mapdemo; import com.google.android.gms.maps.googlemap; import com.google.android.gms.maps.googlemap.onmylocationbuttonclicklistener; import com.google.android.gms.maps.onmapreadycallback; import com.google.android.gms.maps.supportmapfragment; import android.manifest; import android.content.pm.packagemanager; import android.os.bundle; import android.support.annotation.nonnull; import android.support.v4.app.activitycompat; import android.support.v4.content.contextcompat; import android.support.v7.app.appcompatactivity; import android.widget.toast; /** * demo
Read more