| #include <iostream> |
| #include <cstdlib> |
| #include <thrift/protocol/TBinaryProtocol.h> |
| |
| #include "zmq.hpp" |
| #include "TZmqClient.h" |
| #include "Storage.h" |
| |
| using apache::thrift::std::shared_ptr; |
| using apache::thrift::transport::TZmqClient; |
| using apache::thrift::protocol::TBinaryProtocol; |
| |
| int main(int argc, char** argv) { |
| const char* endpoint = "epgm://eth0;239.192.1.1:5555"; |
| int socktype = ZMQ_PUB; |
| int incr = 1; |
| if (argc > 1) { |
| incr = atoi(argv[1]); |
| } |
| |
| zmq::context_t ctx(1); |
| shared_ptr<TZmqClient> transport(new TZmqClient(ctx, endpoint, socktype)); |
| shared_ptr<TBinaryProtocol> protocol(new TBinaryProtocol(transport)); |
| StorageClient client(protocol); |
| |
| transport->open(); |
| |
| client.incr(incr); |
| usleep(50000); |
| |
| return 0; |
| } |