71
71
#define ZMQ_DELETED_FUNCTION
72
72
#endif
73
73
#elif defined(_MSC_VER) && (_MSC_VER >= 1900)
74
- #define ZMQ_HAS_RVALUE_REFS
75
- #define ZMQ_DELETED_FUNCTION = delete
74
+ #define ZMQ_HAS_RVALUE_REFS
75
+ #define ZMQ_DELETED_FUNCTION = delete
76
76
#elif defined(_MSC_VER) && (_MSC_VER >= 1600)
77
77
#define ZMQ_HAS_RVALUE_REFS
78
78
#define ZMQ_DELETED_FUNCTION
@@ -124,10 +124,10 @@ namespace zmq
124
124
return zmq_strerror (errnum);
125
125
}
126
126
#else
127
- virtual const char *what () const throw ()
128
- {
129
- return zmq_strerror (errnum);
130
- }
127
+ virtual const char *what () const throw ()
128
+ {
129
+ return zmq_strerror (errnum);
130
+ }
131
131
#endif
132
132
int num () const
133
133
{
@@ -177,7 +177,7 @@ namespace zmq
177
177
if (rc != 0 )
178
178
throw error_t ();
179
179
}
180
-
180
+
181
181
#ifdef ZMQ_HAS_PROXY_STEERABLE
182
182
inline void proxy_steerable (void *frontend, void *backend, void *capture, void *control)
183
183
{
@@ -186,7 +186,7 @@ namespace zmq
186
186
throw error_t ();
187
187
}
188
188
#endif
189
-
189
+
190
190
inline void version (int *major_, int *minor_, int *patch_)
191
191
{
192
192
zmq_version (major_, minor_, patch_);
@@ -372,6 +372,14 @@ namespace zmq
372
372
return a == b;
373
373
}
374
374
375
+ inline const char * gets (const char *property_) const
376
+ {
377
+ const char * value = zmq_msg_gets (&msg, property);
378
+ if (value == NULL )
379
+ throw error_t ();
380
+ return value;
381
+ }
382
+
375
383
private:
376
384
// The underlying message
377
385
zmq_msg_t msg;
@@ -611,7 +619,7 @@ namespace zmq
611
619
{
612
620
return (ptr != NULL );
613
621
}
614
-
622
+
615
623
inline size_t send (const void *buf_, size_t len_, int flags_ = 0 )
616
624
{
617
625
int nbytes = zmq_send (ptr, buf_, len_, flags_);
@@ -664,7 +672,7 @@ namespace zmq
664
672
return false ;
665
673
throw error_t ();
666
674
}
667
-
675
+
668
676
private:
669
677
inline void init (context_t & context_, int type_)
670
678
{
@@ -704,9 +712,9 @@ namespace zmq
704
712
705
713
rc = zmq_connect (s, addr_);
706
714
assert (rc == 0 );
707
-
715
+
708
716
on_monitor_started ();
709
-
717
+
710
718
while (true ) {
711
719
zmq_msg_t eventMsg;
712
720
zmq_msg_init (&eventMsg);
@@ -723,7 +731,7 @@ namespace zmq
723
731
#else
724
732
zmq_event_t * event = static_cast <zmq_event_t *>(zmq_msg_data (&eventMsg));
725
733
#endif
726
-
734
+
727
735
#ifdef ZMQ_NEW_MONITOR_EVENT_LAYOUT
728
736
zmq_msg_t addrMsg;
729
737
zmq_msg_init (&addrMsg);
0 commit comments