| using apache::thrift::std::shared_ptr; |
| using apache::thrift::TProcessor; |
| using apache::thrift::server::TZmqServer; |
| using apache::thrift::server::TZmqMultiServer; |
| class StorageHandler : virtual public StorageIf { |
| void incr(const int32_t amount) { |
| printf("value_: %i\n", value_) ; |
| int main(int argc, char *argv[]) { |
| shared_ptr<StorageHandler> handler(new StorageHandler()); |
| shared_ptr<TProcessor> processor(new StorageProcessor(handler)); |
| TZmqServer oneway_server(processor, ctx, "epgm://eth0;239.192.1.1:5555", ZMQ_SUB); |