ruby - rabbitmq exchange never publishes to queue binding -


I'm trying to get a basic exchange => The line going on Rabbitmq.

  • My local host is running rabbitmq
  • The rabbitmq web dashboard is available on http: // localhost: 15672 / < Li> I have a message source written in an exchange named "yomtvraps"
  • I have a line called "yomtvraps"
  • I have the binding exchange "yomtvraps"

    I started my message emitter :

      Li> Show all exchanges This web page shows incoming messages at the rate of 80 / s
    • The Exchange page shows a graph with incoming messages http: // localhost: 15672 / # / exchange /% 2 0 messages are outgoing ("... no publications. .. ")

      The queue does not receive anything :

      • I'm never listening to any message receiver
      • to queue page sho Incoming Message draws http: // localhost: 15672 / # / Kyuuj /% 2F / Yontwraps

        Do I even remember? I think there is nothing right between money and queue but what?

        The problem is basically: the routing key was not set for both, and apparently Exchange and queue need that key.

        From: 

          is required "made" NAME_OF_QUEUE = "yomtvraps" NAME_OF_EXCHANGE = "yomtvraps" conn = Bunny.new (: auto_recover = & gt; false) Conn.start ch = conn.create_channel q = ch.queue ("yomtvraps") "" \ tthere says "Already have a line named \" # {NAME_OF_QUEUE} \ "if conn.queue_exists? (NAME_OF_QUEUE) Tthere "if first conn.exchange_exists? (NAME_OF_EXCHANGE) exchange = ch.direct (NAME_OF_EXCHANGE, durable = & gt; true) exchange.publish (" Hello World! ",: Routing_key =" # {NAME_OF_EXCHANGE}} " & Gt; NAME_OF_QUEUE) "[x] 'Hello World!' 'Conn.close   
         receivers enter:  
          "bunny" NAME_OF_QUEUE = "required" yomtvraps "NAME_OF_EXCHANGE =" yomtvraps "conn = Bunny.new ( : Auto_recover = & gt; wrong) conn.start ch = conn.create_channel q = ch.queue (NAME_OF_QUEUE) exchange = ch.direct (NAME_OF_EXCHANGE ,: durable = & gt; true) # Logstash starts like this "[ Waiting for messages is waiting. Subscribe to exit CTRL + C "q.bind (exchange,: routing_key => NAME_OF_QUEUE) (put: block = & gt; true)., Property, body puts" [x] received # Body} "End rescue interrupt => Output (in two different terminals):  
          $ ruby ​​send_exchange.rb Already a queue was named" yomtvraps "before From the same "yomtvraps" the exchange [x] sent Hello World! $ Ruby received_queue.rb [*] Waiting for the message. Get CTRL + C [x] to exit the press Micro world!

Comments

Post a Comment

Popular posts from this blog

Java - Error: no suitable method found for add(int, java.lang.String) -

I'm in the middle of homework work and I'm stuck. At this point in my code, I think that I should have a GUI window that opens and allows me to type "inserted text number". Notice is not going anywhere but at this point, If I pass through the problem then it will be in a linked list. I am getting two of the same error for the lines. Add (index, element); And I can not seem to get past it, there is no suitable method for the error "add (int, java. string string)". Code is below, please advise. To clarify - this will not be a method error because it is a linked list. There should not be any way involved. import java.awt. *; Import java.awt.event. *; Import javax.swing. *; Import java.util. *; Import java.util.Scanner; Import java.util.LinkedList; Public class TopTenList JFrame {Private TopTenList tt; See the Private JTextArea list; Private JTextField cmdTextField; Private JTextField resultsTestfield; // This GUI window is the code for the public toptist...
Read more

java - JPA TypedQuery: Parameter value element did not match expected type -

I am using JPA 2.0 and getting the following code in the DAO layer: Public Zero Test () {string key = "status"; String [] Conditions = {"A", "B"}; & Lt; TestTable & gt; Results = Search (Keys, Conditions); } Public listing & lt; TestTable & gt; Search (string key, object value error) {string sql = "test ndf to testlet and jade nand." + Key + "in:" + key; TypedQuery & LT; TestTable & gt; Query = entityManager.createQuery (SQL, TestTable.class); Query.setParameter (key, Arrays.asList (valueArr)) / *** Error Line *** Return query.getResultList (); } In the above error line, it throws the following exception: java.lang.IllegalArgumentException: parameter value element [[Ljava.lang.String; @ cbe5bc] did not match the expected type [java.lang.String] Why is this expected type string while actually this string []? Please help! Note: This is derived from the normal routine and is a simplified code. I can no...
Read more

c++ - static template member variable has internal linkage but is not defined -

Yes, I know, there is a question with almost the same title, but it refers to a different situation. Error message) In my case, I have a .cpp file with a big named designation name (implementation details). There is a property class template with a static data member in that name space, which I need to access from outside the unknown namespace. I give it a little bit of meat: file.hpp namespace Bar {template & lt; Typename A & gt; Struct foo {static_assert (is_same & lt; a, float & gt; :: value} is_same & lt; a, double>: value, ""); Fixed zero set_static_var (a const & x); // ...}; } and file.cpp namespace {template & lt; Typename A & gt; Struct foo_traits {// supports the implementation of several static code bars: foo & lt; & Gt; Fixed A data; }; The template's & lt; & Gt; Float foo_traits & lt; Float & gt; :: datum; // No change if this is in the global namespace template & lt; & Gt; Doub...
Read more