← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/rabbitmq/rabbitmq_handler.h

  • Committer: Lee Bieber
  • Date: 2011-03-29 22:31:41 UTC
  • mfrom: (2257.1.3 build)
  • Revision ID: kalebral@gmail.com-20110329223141-yxc22h3l2he58sk0
Merge Andrew - 743842: Build failure using GCC 4.6
Merge Stewart - 738022: CachedDirectory silently fails to add entries if stat() fails
Merge Olaf - Common fwd: add copyright, add more declaration

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/rabbitmq/rabbitmq_handler.h
66
66
  const std::string &username;
67
67
  const std::string &password;
68
68
  const std::string &virtualhost;
69
 
  const std::string &exchange;
70
 
  const std::string &routingKey;
71
69
public:
72
70
  /**
73
71
   * @brief
89
87
                  const in_port_t port, 
90
88
                  const std::string &username, 
91
89
                  const std::string &password, 
92
 
                  const std::string &virtualhost,
93
 
                  const std::string &exchange,
94
 
                  const std::string &routingKey)
 
90
                  const std::string &virtualhost)
95
91
    throw(rabbitmq_handler_exception);
96
92
 
97
93
  ~RabbitMQHandler();
105
101
   *
106
102
   * @param[in] message the message to send
107
103
   * @param[in] length the length of the message
 
104
   * @param[in] exchangeName name of the exchange to publish to
 
105
   * @param[in] routingKey the routing key to use
108
106
   * @throw exception if there is a problem publishing
109
107
   */
110
108
  void publish(void *message, 
111
 
               const int length)
 
109
               const int length, 
 
110
               const std::string &exchangeName, 
 
111
               const std::string &routingKey)
112
112
    throw(rabbitmq_handler_exception);
113
113
 
114
 
  void reconnect() throw(rabbitmq_handler_exception);
115
 
  void disconnect() throw(rabbitmq_handler_exception);
116
114
 
117
115
private:
118
116
  /**
128
126
   * @throw exception with the message unless the command was successful
129
127
   */
130
128
  void handleAMQPError(amqp_rpc_reply_t x, std::string context) throw(rabbitmq_handler_exception);
131
 
 
132
 
  void connect() throw(rabbitmq_handler_exception);
133
 
 
134
129
};
135
130
 
136
131
} /* namespace drizzle_plugin */