1 #ifndef PROTON_CODEC_DECODER_HPP 2 #define PROTON_CODEC_DECODER_HPP 25 #include "../internal/data.hpp" 26 #include "../internal/type_traits.hpp" 27 #include "../types_fwd.hpp" 28 #include "./common.hpp" 56 explicit decoder(
const data& d,
bool exact=
false) : data(d), exact_(exact) {}
60 PN_CPP_EXTERN
explicit decoder(
const internal::value_base&,
bool exact=
false);
64 PN_CPP_EXTERN
void decode(
const char* buffer,
size_t size);
68 PN_CPP_EXTERN
void decode(
const std::string&);
71 PN_CPP_EXTERN
bool more();
78 PN_CPP_EXTERN
type_id next_type();
87 PN_CPP_EXTERN decoder& operator>>(uint8_t&);
88 PN_CPP_EXTERN decoder& operator>>(int8_t&);
89 PN_CPP_EXTERN decoder& operator>>(uint16_t&);
90 PN_CPP_EXTERN decoder& operator>>(int16_t&);
91 PN_CPP_EXTERN decoder& operator>>(uint32_t&);
92 PN_CPP_EXTERN decoder& operator>>(int32_t&);
93 PN_CPP_EXTERN decoder& operator>>(
wchar_t&);
94 PN_CPP_EXTERN decoder& operator>>(uint64_t&);
95 PN_CPP_EXTERN decoder& operator>>(int64_t&);
96 PN_CPP_EXTERN decoder& operator>>(
timestamp&);
97 PN_CPP_EXTERN decoder& operator>>(
float&);
98 PN_CPP_EXTERN decoder& operator>>(
double&);
99 PN_CPP_EXTERN decoder& operator>>(
decimal32&);
100 PN_CPP_EXTERN decoder& operator>>(
decimal64&);
101 PN_CPP_EXTERN decoder& operator>>(
decimal128&);
102 PN_CPP_EXTERN decoder& operator>>(
uuid&);
103 PN_CPP_EXTERN decoder& operator>>(std::string&);
104 PN_CPP_EXTERN decoder& operator>>(
symbol&);
105 PN_CPP_EXTERN decoder& operator>>(
binary&);
106 PN_CPP_EXTERN decoder& operator>>(
message_id&);
108 PN_CPP_EXTERN decoder& operator>>(
scalar&);
109 PN_CPP_EXTERN decoder& operator>>(internal::value_base&);
110 PN_CPP_EXTERN decoder& operator>>(null&);
117 PN_CPP_EXTERN decoder& operator>>(
start&);
121 PN_CPP_EXTERN decoder& operator>>(
const finish&);
124 template <
class T>
struct sequence_ref { T& ref; sequence_ref(T& r) : ref(r) {} };
125 template <
class T>
struct associative_ref { T& ref; associative_ref(T& r) : ref(r) {} };
126 template <
class T>
struct pair_sequence_ref { T& ref; pair_sequence_ref(T& r) : ref(r) {} };
128 template <
class T>
static sequence_ref<T> sequence(T& x) {
return sequence_ref<T>(x); }
129 template <
class T>
static associative_ref<T> associative(T& x) {
return associative_ref<T>(x); }
130 template <
class T>
static pair_sequence_ref<T> pair_sequence(T& x) {
return pair_sequence_ref<T>(x); }
139 if (s.is_described) next();
140 r.ref.resize(s.size);
141 for (
typename T::iterator i = r.ref.begin(); i != r.ref.end(); ++i)
147 template <
class T> decoder&
operator>>(associative_ref<T> r) {
148 using namespace internal;
153 for (
size_t i = 0; i < s.size/2; ++i) {
154 typename remove_const<typename T::key_type>::type k;
155 typename remove_const<typename T::mapped_type>::type v;
164 template <
class T> decoder&
operator>>(pair_sequence_ref<T> r) {
165 using namespace internal;
170 for (
size_t i = 0; i < s.size/2; ++i) {
171 typedef typename T::value_type value_type;
172 typename remove_const<typename value_type::first_type>::type k;
173 typename remove_const<typename value_type::second_type>::type v;
175 r.ref.push_back(value_type(k, v));
182 template <
class T,
class U> decoder& extract(T& x, U (*
get)(pn_data_t*));
190 template<
class T> T
get(
decoder& d) {
200 template <
class T>
typename internal::enable_if<internal::is_unknown_integer<T>::value,
decoder&>::type
202 using namespace internal;
203 typename integer_type<sizeof(T), is_signed<T>::value>::type v;
212 #endif // PROTON_CODEC_DECODER_HPP A holder for an instance of any scalar AMQP type.
Definition: scalar.hpp:35
An AMQP message.
Definition: message.hpp:51
Experimental - Start encoding a complex type.
Definition: common.hpp:31
A key for use with AMQP annotation maps.
Definition: annotation_key.hpp:33
A sequence of key-value pairs.
Definition: type_id.hpp:63
A 16-byte universally unique identifier.
Definition: uuid.hpp:34
decoder & operator>>(sequence_ref< T > r)
Extract any AMQP sequence (ARRAY, LIST or MAP) to a C++ sequence container of T if the elements types...
Definition: decoder.hpp:136
decoder & operator>>(associative_ref< T > r)
Extract an AMQP MAP to a C++ associative container.
Definition: decoder.hpp:147
64-bit decimal floating point.
Definition: decimal.hpp:51
A std::string that represents the AMQP symbol type.
Definition: symbol.hpp:30
Arbitrary binary data.
Definition: binary.hpp:34
128-bit decimal floating point.
Definition: decimal.hpp:54
type_id
An identifier for AMQP types.
Definition: type_id.hpp:38
32-bit decimal floating point.
Definition: decimal.hpp:48
A 64-bit timestamp in milliseconds since the Unix epoch.
Definition: timestamp.hpp:30
decoder & operator>>(pair_sequence_ref< T > r)
Extract an AMQP MAP to a C++ push_back sequence of pairs preserving encoded order.
Definition: decoder.hpp:164
void assert_type_equal(type_id want, type_id got)
Throw a conversion_error if want != got with a message including the names of the types...
internal::enable_if< internal::is_unknown_integer< T >::value, decoder & >::type operator>>(decoder &d, T &i)
operator>> for integer types that are not covered by the standard overrides.
Definition: decoder.hpp:201
Experimental - Finish inserting or extracting a complex type.
Definition: common.hpp:54
decoder(const data &d, bool exact=false)
Wrap a Proton C data object.
Definition: decoder.hpp:56
Type traits for mapping between AMQP and C++ types.
Definition: annotation_key.hpp:28
Experimental - Stream-like decoder from AMQP bytes to C++ values.
Definition: decoder.hpp:51
An AMQP message ID.
Definition: message_id.hpp:42