← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/rabbitmq/rabbitmq_log.cc

  • Committer: Brian Aker
  • Date: 2010-12-24 21:27:54 UTC
  • mto: (2035.1.1 clean)
  • mto: This revision was merged to the branch mainline in revision 2037.
  • Revision ID: brian@tangent.org-20101224212754-85xvjullymvhibr9
Merge in cast() for BOOLEAN.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/rabbitmq/rabbitmq_log.cc
22
22
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
23
23
 */
24
24
 
25
 
#include <config.h>
 
25
#include "config.h"
26
26
#include "rabbitmq_log.h"
27
27
#include <drizzled/message/transaction.pb.h>
28
28
#include <google/protobuf/io/coded_stream.h>
69
69
  uint8_t* buffer= new uint8_t[message_byte_length];
70
70
  if(buffer == NULL)
71
71
  {
72
 
    errmsg_printf(error::ERROR, _("Failed to allocate enough memory to transaction message\n"));
 
72
    errmsg_printf(ERRMSG_LVL_ERROR, _("Failed to allocate enough memory to transaction message\n"));
73
73
    deactivate();
74
74
    return plugin::UNKNOWN_ERROR;
75
75
  }
84
84
  }
85
85
  catch(exception& e)
86
86
  {
87
 
    errmsg_printf(error::ERROR, _(e.what()));
 
87
    errmsg_printf(ERRMSG_LVL_ERROR, _(e.what()));
88
88
    deactivate();
89
89
    return plugin::UNKNOWN_ERROR;
90
90
  }
114
114
  } 
115
115
  catch (exception& e) 
116
116
  {
117
 
    errmsg_printf(error::ERROR, _("Failed to allocate the RabbitMQHandler.  Got error: %s\n"),
 
117
    errmsg_printf(ERRMSG_LVL_ERROR, _("Failed to allocate the RabbitMQHandler.  Got error: %s\n"),
118
118
                  e.what());
119
119
    return 1;
120
120
  }
127
127
  } 
128
128
  catch (exception& e) 
129
129
  {
130
 
    errmsg_printf(error::ERROR, _("Failed to allocate the RabbitMQLog instance.  Got error: %s\n"), 
 
130
    errmsg_printf(ERRMSG_LVL_ERROR, _("Failed to allocate the RabbitMQLog instance.  Got error: %s\n"), 
131
131
                  e.what());
132
132
    return 1;
133
133
  }
152
152
{
153
153
  context("host", 
154
154
          po::value<string>()->default_value("localhost"),
155
 
          _("Host name to connect to"));
 
155
          N_("Host name to connect to"));
156
156
  context("port",
157
157
          po::value<port_constraint>(&sysvar_rabbitmq_port)->default_value(5672),
158
 
          _("Port to connect to"));
 
158
          N_("Port to connect to"));
159
159
  context("virtualhost",
160
160
          po::value<string>()->default_value("/"),
161
 
          _("RabbitMQ virtualhost"));
 
161
          N_("RabbitMQ virtualhost"));
162
162
  context("username",
163
163
          po::value<string>()->default_value("guest"),
164
 
          _("RabbitMQ username"));
 
164
          N_("RabbitMQ username"));
165
165
  context("password",
166
166
          po::value<string>()->default_value("guest"),
167
 
          _("RabbitMQ password"));
 
167
          N_("RabbitMQ password"));
168
168
  context("use-replicator",
169
169
          po::value<string>()->default_value("default_replicator"),
170
 
          _("Name of the replicator plugin to use (default='default_replicator')"));
 
170
          N_("Name of the replicator plugin to use (default='default_replicator')"));
171
171
  context("exchange",
172
172
          po::value<string>()->default_value("ReplicationExchange"),
173
 
          _("Name of RabbitMQ exchange to publish to"));
 
173
          N_("Name of RabbitMQ exchange to publish to"));
174
174
  context("routingkey",
175
175
          po::value<string>()->default_value("ReplicationRoutingKey"),
176
 
          _("Name of RabbitMQ routing key to use"));
 
176
          N_("Name of RabbitMQ routing key to use"));
177
177
}
178
178
 
179
179
} /* namespace drizzle_plugin */