back soft

Vote count: 0 I have an old Debian (Lenny), on which I develop an application that should connect to RabbitMQ. I downloaded the official C++ client rabbitmq-c-0.8.0 from https://github.com/alanxz/rabbitmq-c/releases/tag/v0.8.0 , but unfortunately, I can't compile it on my old Debian: wget https://github.com/alanxz/rabbitmq-c/archive/v0.8.0.tar.gz tar zxvf v0.8.0.tar.gz autoreconf -i Result: autoreconf -i /usr/share/aclocal/libmcrypt.m4:17: waing: underquoted definition of AM_PATH_LIBMCRYPT /usr/share/aclocal/libmcrypt.m4:17: run info '(automake)Extending aclocal' /usr/share/aclocal/libmcrypt.m4:17: or see http://sources.redhat.com/automake/automake.html#Extending-aclocal Makefile.am:6: Libtool library used but `LIBTOOL' is undefined Makefile.am:6: The usual way to define `LIBTOOL' is to add `AC_PROG_LIBTOOL' Makefile.am:6: to `configure.ac' and run `aclocal' and `auto,rabbitmq c client,rabbitmq c client tutorial,rabbitmq c client windows,rabbitmq c client heartbeat,rabbitmq c client ssl,rabbitmq c client linux,amqp c client,rabbitmq objective-c client,rabbitmq client lib,objective-c-rabbitmq-client-not-publishing-messages-to-queue ...ادامه مطلب

Vote count: 0 I've just installed Erlang 19.0, then Rabbitmq Server 3.6.3. OS - Windows 10. Then I installed rabbitmq_management plugin, then I started rabbitmq-server. I can successfully login into management console. The problem is when I go to Queues I get as error: Got response code 500 with body {"error":"JSON encode error: {bad_term,#{error_logger => true,kill => true,size => 0}}","reason":"While encoding: n[{total_count,1},n {item_count,1},n {filtered_count,1},n {page,1},n {page_size,100},n {page_count,1},n {items,n [[{memory,22048},n {reductions,6633},n {reductions_details,[{rate,0.0}]},n {messages,0},n {messages_details,[{rate,0.0}]},n {messages_ready,0},n {messages_ready_details,[{rate,0.0}]},n {messages_unacknowledged,0},n {messages_unacknowledged_details,[{rate,0.0}]},n {idle_since,<<"2016-07-08 20:55:04">>},n {consumer_utilisation,''},n {policy,''},n {exclusive_consumer_tag,''},n {consumers,1},n {recoverable_slaves,''},n {state,running},n {reductions,6633},n {garbage_collection,n [{max_heap_size,#{error_logger => true,kill => true,size => 0}},n {min_bin_vheap_size,46422},n {min_heap_size,233},n {fullsweep_after,65535},n {minor_gcs,3}]},n {messages_ram,0},n {messages_ready_ram,0},n {messages_unacknowledged_ram,0},n {messages_persistent,0},n {message_bytes,0},n {message_bytes_ready,0},n {message_bytes_unacknowledged,0},n {message_bytes_ram,0},n {message_bytes_persistent,0},n {head_message_timestamp,''},n {disk_reads,0},n {disk_writes,0},n {backing_queue_status,n {struct,n [{mode,default},n {q1,0},n {q2,0},n {delta,[delta,undefined,0,undefined]},n {q3,0},n {q4,0},n {len,0},n {target_ram_count,infinity},n {next_seq_id,0},n {avg_ingress_rate,0.0},n {avg_egress_rate,0.0},n {avg_ack_ingress_rate,0.0},n {avg_ack_egress_rate,0.0}]}},n {node,'rabbit@DESKTOP-330SD1I'},n {arguments,{struct,[]}},n {exclusive,false},n {auto_delete,false},n {durable,true},n {vhost,<<"/">>},n {name,<<"queue1">>}]]}]"} If I r, ...ادامه مطلب

Vote count: 0 We're running several windows server with RabbitMQ and salt minion on it. Our aim is to control and configure RabbitMQ via salt. The first problem with which we had been confronted was 'rabbitmq' __virtual__ retued false After digging in the source code, we solved this by adding the rabbitmq sbin folder to the PATH. The next error ERROR: password is a required argument for runas on Windows was pretty easy to solve. Just add a runas="" after your call and it's fine. ... or not ERROR: Unable to run command '['rabbitmqctl', 'status']' with the context '{'timeout': None, 'with_communicate': True, 'shell': False, 'bg': False, 'stderr': -2, 'env': {'TMP': 'C:\Windows\TEMP', 'COMPUTERNAME': 'TMS-230017010', 'USERDOMAIN': 'WORKGROUP', 'PSMODULEPATH': 'C:\Windows\system32\WindowsPowerShell\v1.0\Modules\;c:\Program Files (x86)\Microsoft SQL Server\110\Tools\PowerShell\Modules\', 'COMMONPROGRAMFILES': 'C:\Program Files\Common Files', 'PROCESSOR_IDENTIFIER': 'Intel64 Family 6 Model 44 Stepping 2, GenuineIntel', 'PROGRAMFILES': 'C:\Program Files', 'PROCESSOR_REVISION': '2c02', 'SYSTEMROOT': 'C:\Windows', 'PATH': '%programfiles%\rabbitmq server\rabbitmq_server-3.6.1\sbin;c:\programdata\oracle\java\javapath;C:\Windows\system32;C:\Windows;C:\Windows\system32\wbem;C:\Windows\system32\windowspowershell\v1.0;c:\program files (x86)\microsoft sql server\110\tools\binn;c:\program files\microsoft sql server\110\tools\binn;c:\program files\microsoft sql server\110\dts\binn;c:\program files (x86)\microsoft sql server\110\tools\binn\managementstudio;c:\program files (x86)\microsoft sql server\110\dts\binn;C:\Program Files\rabbitmq server\rabbitmq_server-3.6.1\sbin;C:\salt\bin\lib\site-packages\pywin32_system32;/bin;/sbin;/usr/bin;/usr/sbin;/usr/local/bin;C:\salt\bin\lib\site-packages\pywin32_system32', 'PROGRAMFILES(X86)': 'C:\Program Files (x86)', 'TEMP': 'C:\Windows\TEMP', 'COMMONPROGRAMFILES(X86)': 'C:\Program Files (x86)\Common Files', 'PROCESSOR_ARCHITECTURE', ...ادامه مطلب

Vote count: 0 I am trying to pass a python dictionary to a rabbitmq queue via pika, this is probably a python problem and not rabbitmq itself. I am getting an error as stated above and here is my code: def PingAddScan(deviceID, ipAddress, deviceHistory, item, date, apiURL, browserConId): if PingDevice(deviceID, ipAddress): BasicScan(ipAddress, deviceID, item, apiURL) deviceHistory[deviceID] = date # After the basic scan we are going to need to push a message back to the user to say # that the pathfinder has successfully found the device, and it should prompt the user # what he wants to scan print browserConId + " : " + deviceID channelOutbound.queue_declare(queue='outboundMessaging', durable=True) message = {"browserConnectionID": browserConId, "data": "FOUND", "deviceID": deviceID} print str(message) channelOutbound.basic_publish(exchange='messaging', routing_key='outbound', body=message) and here is the full stack trace: Traceback (most recent call last): File "pathfinderAllocator.py", line 454, in <module> channel.start_consuming() File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 1755, in start_consuming self.connection.process_data_events(time_limit=None) File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 715, in process_data_events self._dispatch_channel_events() File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 518, in _dispatch_channel_events impl_channel._get_cookie()._dispatch_events() File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 1384, in _dispatch_events evt.body) File "pathfinderAllocator.py", line 439, in callback PingAddScan(deviceID, ipAddress, deviceHistory, new_device, date, data, browser_connec, ...ادامه مطلب

Vote count: 0 Couldn't find any other questions related to this specific error. I can't seem to hook up my Spring Boot WebSocket demo project with RabbitMQ. Note that everything works fine when using the "simple" broker, but when hooking up the stomp broker with Rabbit, I get the following error (keeps trying to reconnect): Java HotSpot(TM) Client VM waing: You have loaded library /tmp/libnetty-transport-native-epoll8916930274033685449.so which might have disabled stack guard. The VM will try to fix the stack guard now. It's highly recommended that you fix the library with 'execstack -c <libfile>', or link it with '-z noexecstack'. 2016-03-07 22:35:13.993 INFO 4047 --- [ main] o.s.m.s.s.StompBrokerRelayMessageHandler : Started. 2016-03-07 22:35:14.045 INFO 4047 --- [eactor-tcp-io-1] r.io.net.impl.netty.tcp.NettyTcpClient : CONNECTED: [id: 0x034a269f, /127.0.0.1:39955 => /127.0.0.1:25672] 2016-03-07 22:35:14.151 INFO 4047 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8080 (http) 2016-03-07 22:35:14.158 INFO 4047 --- [ main] com.chat.ChatApplication : Started ChatApplication in 8.921 seconds (JVM running for 17.336) 2016-03-07 22:35:21.028 INFO 4047 --- [eactor-tcp-io-1] r.io.net.impl.netty.tcp.NettyTcpClient : CLOSED: [id: 0x034a269f, /127.0.0.1:39955 :> /127.0.0.1:25672] 2016-03-07 22:35:21.030 INFO 4047 --- [eactor-tcp-io-1] r.io.net.impl.netty.tcp.NettyTcpClient : Failed to connect to /127.0.0.1:25672. Attempting reconnect in 5000ms. Just to be sure I'm pointing at the right point, I run: matthew@matthew ~/code/chat $ epmd -names epmd: up and running on port 4369 with data: name rabbit at port 25672 Here's my WebSocketConfig: package com.chat.shared.websocket; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.sp, ...ادامه مطلب

Vote count: 0 I am very new to RabbitMQ so my question might be a bit naive and hopefully easily resolved. I want to dispatch some heavy computational tasks to other machines. To that end I thought I could use pika and RabbitMQ. My setup is as follows: The a RabbitMQ server is running in the official docker image on one machine. Other machines are running docker container with my libraries and pika. For sending and consuming the jobs I basically use the setup described in the second tutorial which uses pika.BlockingConnection and pika.BlockingConnection along with channel.basic_ack(delivery_tag = method.delivery_tag) once the job is computed. Generally, the setup works fine and the jobs are started. However, while the job is running, the consumer disappears from the queue for reasons that I don't understand. This causes RabbitMQ to send the same job to another consumer. Needless to say that this is unwanted behaviour. Now I have several questions: Does anyone have an idea why the consumers disappear? They run python code which calls another C-library. How could I debug what causes the consumers to disappear? Maybe my RabbitMQ/pika setup is not ideal for my goal. Does anyone have a better suggestion that gives me an overview how many consumers are running, potentially ping the jobs while they are computing, and ideally determine whether the execution of a particular job resulted in an error? Thanks for all suggestions. asked 2 mins agofabee This entry passed through the Full-Text RSS service - if this is your content and you're reading it on someone else's site, please read the FAQ at fivefilters.org/content-only/faq.php#publishers., ...ادامه مطلب