69
69
uint8_t* buffer= new uint8_t[message_byte_length];
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"));
74
74
return plugin::UNKNOWN_ERROR;
154
154
po::value<string>()->default_value("localhost"),
155
_("Host name to connect to"));
155
N_("Host name to connect to"));
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"));
179
179
} /* namespace drizzle_plugin */