Class: OracleDB::DeqOptions

Inherits:
Object
  • Object
show all
Defined in:
ext/oracledb/rboradb_aq.c

Instance Method Summary collapse

Constructor Details

#initialize(conn) ⇒ Object



109
110
111
112
113
114
115
116
117
118
119
# File 'ext/oracledb/rboradb_aq.c', line 109

static VALUE deqopts_initialize(VALUE self, VALUE conn)
{
    DeqOptions_t *opts = To_DeqOptions(self);
    rbOraDBConn *dconn = rboradb_get_dconn(conn);

    RBORADB_INIT(opts, dconn);
    if (dpiConn_newDeqOptions(dconn->handle, &opts->handle) != DPI_SUCCESS) {
        rboradb_raise_error(dconn->ctxt);
    }
    return Qnil;
}

Instance Method Details

#conditionObject



121
122
123
124
# File 'ext/oracledb/rboradb_aq.c', line 121

static VALUE deqopts_condition(VALUE self)
{
    GET_STR(DeqOptions, Condition);
}

#condition=(obj) ⇒ Object



126
127
128
129
# File 'ext/oracledb/rboradb_aq.c', line 126

static VALUE deqopts_set_condition(VALUE self, VALUE obj)
{
    SET_STR(DeqOptions, Condition);
}

#consumer_nameObject



131
132
133
134
# File 'ext/oracledb/rboradb_aq.c', line 131

static VALUE deqopts_consumer_name(VALUE self)
{
    GET_STR(DeqOptions, ConsumerName);
}

#consumer_name=(obj) ⇒ Object



136
137
138
139
# File 'ext/oracledb/rboradb_aq.c', line 136

static VALUE deqopts_set_consumer_name(VALUE self, VALUE obj)
{
    SET_STR(DeqOptions, ConsumerName);
}

#correlationObject



141
142
143
144
# File 'ext/oracledb/rboradb_aq.c', line 141

static VALUE deqopts_correlation(VALUE self)
{
    GET_STR(DeqOptions, Correlation);
}

#correlation=(obj) ⇒ Object



146
147
148
149
# File 'ext/oracledb/rboradb_aq.c', line 146

static VALUE deqopts_set_correlation(VALUE self, VALUE obj)
{
    SET_STR(DeqOptions, Correlation);
}

#delivery_mode=(obj) ⇒ Object



151
152
153
154
# File 'ext/oracledb/rboradb_aq.c', line 151

static VALUE deqopts_set_delivery_mode(VALUE self, VALUE obj)
{
    SET_ENUM(DeqOptions, DeliveryMode, dpiMessageDeliveryMode);
}

#modeObject



156
157
158
159
# File 'ext/oracledb/rboradb_aq.c', line 156

static VALUE deqopts_mode(VALUE self)
{
    GET_ENUM(DeqOptions, Mode, dpiDeqMode);
}

#mode=(obj) ⇒ Object



161
162
163
164
# File 'ext/oracledb/rboradb_aq.c', line 161

static VALUE deqopts_set_mode(VALUE self, VALUE obj)
{
    SET_ENUM(DeqOptions, Mode, dpiDeqMode);
}

#msg_idObject



166
167
168
169
# File 'ext/oracledb/rboradb_aq.c', line 166

static VALUE deqopts_msg_id(VALUE self)
{
    GET_STR(DeqOptions, MsgId);
}

#msg_id=(obj) ⇒ Object



171
172
173
174
# File 'ext/oracledb/rboradb_aq.c', line 171

static VALUE deqopts_set_msg_id(VALUE self, VALUE obj)
{
    SET_STR(DeqOptions, MsgId);
}


176
177
178
179
# File 'ext/oracledb/rboradb_aq.c', line 176

static VALUE deqopts_navigation(VALUE self)
{
    GET_ENUM(DeqOptions, Navigation, dpiDeqNavigation);
}


181
182
183
184
# File 'ext/oracledb/rboradb_aq.c', line 181

static VALUE deqopts_set_navigation(VALUE self, VALUE obj)
{
    SET_ENUM(DeqOptions, Navigation, dpiDeqNavigation);
}

#transformationObject



186
187
188
189
# File 'ext/oracledb/rboradb_aq.c', line 186

static VALUE deqopts_transformation(VALUE self)
{
    GET_STR(DeqOptions, Transformation);
}

#transformation=(obj) ⇒ Object



191
192
193
194
# File 'ext/oracledb/rboradb_aq.c', line 191

static VALUE deqopts_set_transformation(VALUE self, VALUE obj)
{
    SET_STR(DeqOptions, Transformation);
}

#visibilityObject



196
197
198
199
# File 'ext/oracledb/rboradb_aq.c', line 196

static VALUE deqopts_visibility(VALUE self)
{
    GET_ENUM(DeqOptions, Visibility, dpiVisibility);
}

#visibility=(obj) ⇒ Object



201
202
203
204
# File 'ext/oracledb/rboradb_aq.c', line 201

static VALUE deqopts_set_visibility(VALUE self, VALUE obj)
{
    SET_ENUM(DeqOptions, Visibility, dpiVisibility);
}

#waitObject



206
207
208
209
# File 'ext/oracledb/rboradb_aq.c', line 206

static VALUE deqopts_wait(VALUE self)
{
    GET_UINT32(DeqOptions, Wait);
}

#wait=(obj) ⇒ Object



211
212
213
214
# File 'ext/oracledb/rboradb_aq.c', line 211

static VALUE deqopts_set_wait(VALUE self, VALUE obj)
{
    SET_UINT32(DeqOptions, Wait);
}