src/core/sandesha2_msg_ctx.c

/*
 * Copyright 2004,2005 The Apache Software Foundation.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#include <sandesha2_msg_ctx.h>
#include <sandesha2_constants.h>
#include <axutil_hash.h>
#include <axiom_soap_const.h>
#include <stdio.h>
#include <sandesha2_close_seq.h>
#include <sandesha2_close_seq_res.h>
#include <sandesha2_create_seq.h>
#include <sandesha2_create_seq_res.h>
#include <sandesha2_make_connection.h>
#include <sandesha2_msg_pending.h>
#include <sandesha2_seq_ack.h>
#include <sandesha2_seq.h>
#include <sandesha2_terminate_seq.h>
#include <sandesha2_terminate_seq_res.h>

/** 
 * @brief Msg Ctx struct impl
 *	Sandesha2 Message Context
 */
struct sandesha2_msg_ctx_t
{
    int msg_type;
    axis2_char_t *rm_ns_val;
    axis2_char_t *addr_ns_val;
    axis2_char_t *spec_ver;
	axis2_msg_ctx_t *msg_ctx;
    sandesha2_close_seq_t *close_seq;
    sandesha2_close_seq_res_t *close_seq_res;
    sandesha2_create_seq_t *create_seq;
    sandesha2_create_seq_res_t *create_seq_res;
    sandesha2_make_connection_t *make_connection;
    sandesha2_msg_pending_t *msg_pending;
    sandesha2_seq_ack_t *seq_ack;
    sandesha2_seq_t *seq;
    sandesha2_terminate_seq_t *terminate_seq;
    sandesha2_terminate_seq_res_t *terminate_seq_res;
    sandesha2_ack_requested_t *ack_requested;
    axis2_bool_t is_server_side;
};

AXIS2_EXTERN sandesha2_msg_ctx_t* AXIS2_CALL
sandesha2_msg_ctx_create(
    const axutil_env_t *env, 
    axis2_msg_ctx_t *msg_ctx)
{
    sandesha2_msg_ctx_t *rm_msg_ctx = NULL;
    
    rm_msg_ctx =  (sandesha2_msg_ctx_t *)AXIS2_MALLOC(env->allocator, sizeof(sandesha2_msg_ctx_t));
	
    if(!rm_msg_ctx)
	{
		AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
        return NULL;
	}
    rm_msg_ctx->rm_ns_val = NULL;
    rm_msg_ctx->addr_ns_val = NULL;
    rm_msg_ctx->msg_ctx = NULL;
    rm_msg_ctx->spec_ver = NULL;
    rm_msg_ctx->create_seq = NULL;
    rm_msg_ctx->create_seq_res = NULL;
    rm_msg_ctx->close_seq = NULL;
    rm_msg_ctx->close_seq_res = NULL;
    rm_msg_ctx->terminate_seq = NULL;
    rm_msg_ctx->terminate_seq_res = NULL;
    rm_msg_ctx->make_connection = NULL;
    rm_msg_ctx->msg_pending = NULL;
    rm_msg_ctx->seq = NULL;
    rm_msg_ctx->seq_ack = NULL;
    rm_msg_ctx->ack_requested = NULL;
    
    rm_msg_ctx->msg_type = SANDESHA2_MSG_TYPE_UNKNOWN;
    rm_msg_ctx->msg_ctx = msg_ctx;
    rm_msg_ctx->is_server_side = AXIS2_FALSE;

	return rm_msg_ctx;
}


axis2_status_t AXIS2_CALL 
sandesha2_msg_ctx_free(
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env)
{
    if(rm_msg_ctx->addr_ns_val)
    {
        AXIS2_FREE(env->allocator, rm_msg_ctx->addr_ns_val);
        rm_msg_ctx->addr_ns_val = NULL;
    }
    if(rm_msg_ctx->rm_ns_val)
    {
        AXIS2_FREE(env->allocator, rm_msg_ctx->rm_ns_val);
        rm_msg_ctx->rm_ns_val = NULL;
    }
    if(rm_msg_ctx->spec_ver)
    {
        AXIS2_FREE(env->allocator, rm_msg_ctx->spec_ver);
        rm_msg_ctx->spec_ver = NULL;
    }
    if(rm_msg_ctx->close_seq)
    {
        sandesha2_close_seq_free(rm_msg_ctx->close_seq, env);
        rm_msg_ctx->close_seq = NULL;
    }
    if(rm_msg_ctx->close_seq_res)
    {
        sandesha2_close_seq_res_free(rm_msg_ctx->close_seq_res, env);
        rm_msg_ctx->close_seq_res = NULL;
    }
    if(rm_msg_ctx->create_seq)
    {
        sandesha2_create_seq_free(rm_msg_ctx->create_seq, env);
        rm_msg_ctx->create_seq = NULL;
    }
    if(rm_msg_ctx->create_seq_res)
    {
        sandesha2_create_seq_res_free(rm_msg_ctx->create_seq_res, env);
        rm_msg_ctx->create_seq_res = NULL;
    }
    if(rm_msg_ctx->make_connection)
    {
        sandesha2_make_connection_free(rm_msg_ctx->make_connection, env);
        rm_msg_ctx->make_connection = NULL;
    }
    if(rm_msg_ctx->msg_pending)
    {
        sandesha2_msg_pending_free(rm_msg_ctx->msg_pending, env);
        rm_msg_ctx->msg_pending = NULL;
    }
    if(rm_msg_ctx->seq_ack)
    {
        sandesha2_seq_ack_free(rm_msg_ctx->seq_ack, env);
        rm_msg_ctx->seq_ack = NULL;
    }
    if(rm_msg_ctx->seq)
    {
        sandesha2_seq_free(rm_msg_ctx->seq, env);
        rm_msg_ctx->seq = NULL;
    }
    if(rm_msg_ctx->terminate_seq)
    {
        sandesha2_terminate_seq_free(rm_msg_ctx->terminate_seq, env);
        rm_msg_ctx->terminate_seq = NULL;
    }
    if(rm_msg_ctx->terminate_seq_res)
    {
        sandesha2_terminate_seq_res_free(rm_msg_ctx->terminate_seq_res, env);
        rm_msg_ctx->terminate_seq = NULL;
    }
    if(rm_msg_ctx->ack_requested)
    {
        sandesha2_ack_requested_free(rm_msg_ctx->ack_requested, env);
        rm_msg_ctx->ack_requested = NULL;
    }

	AXIS2_FREE(env->allocator, rm_msg_ctx);
	return AXIS2_SUCCESS;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_msg_ctx(
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env, 
    axis2_msg_ctx_t *msg_ctx)
{
    AXIS2_PARAM_CHECK(env->error, msg_ctx, AXIS2_FAILURE);
    
    rm_msg_ctx->msg_ctx = msg_ctx;
    return AXIS2_SUCCESS;
}
            
axis2_msg_ctx_t *AXIS2_CALL
sandesha2_msg_ctx_get_msg_ctx(
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env)
{
    return rm_msg_ctx->msg_ctx;
}
    
axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_add_soap_envelope(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    int soap_ver = AXIOM_SOAP11;
    axiom_soap_envelope_t *soap_envelope = NULL;
    
    if(!axis2_msg_ctx_get_is_soap_11(rm_msg_ctx->msg_ctx, env))
    {
        soap_ver = AXIOM_SOAP12;
    }

    soap_envelope = axis2_msg_ctx_get_soap_envelope(rm_msg_ctx->msg_ctx, env);
    if(!soap_envelope)
    {
        soap_envelope = axiom_soap_envelope_create_default_soap_envelope(env, soap_ver);
        axis2_msg_ctx_set_soap_envelope(rm_msg_ctx->msg_ctx, env, soap_envelope);
    }
    
    if(rm_msg_ctx->close_seq)
    {
        sandesha2_close_seq_to_soap_envelope(rm_msg_ctx->close_seq, env, 
            soap_envelope);
    }

    if(rm_msg_ctx->close_seq_res)
    {
        sandesha2_close_seq_res_to_soap_envelope(rm_msg_ctx->close_seq_res, env, soap_envelope);
    }
    if(rm_msg_ctx->create_seq)
    {
        sandesha2_create_seq_to_soap_envelope(rm_msg_ctx->create_seq, env, soap_envelope);
    }
    if(rm_msg_ctx->create_seq_res)
    {
        sandesha2_create_seq_res_to_soap_envelope(rm_msg_ctx->create_seq_res, env, soap_envelope);
    }
    if(rm_msg_ctx->make_connection)
    {
        sandesha2_make_connection_to_soap_envelope(rm_msg_ctx->make_connection, env, soap_envelope);
    }
    if(rm_msg_ctx->msg_pending)
    {
        sandesha2_msg_pending_to_soap_envelope(rm_msg_ctx->msg_pending, env, soap_envelope);
    }
    if(rm_msg_ctx->seq_ack)
    {
        sandesha2_seq_ack_to_soap_envelope(rm_msg_ctx->seq_ack, env, soap_envelope);
    }
    if(rm_msg_ctx->seq)
    {
        sandesha2_seq_to_soap_envelope(rm_msg_ctx->seq, env, soap_envelope);
    }
    if(rm_msg_ctx->terminate_seq)
    {
        sandesha2_terminate_seq_to_soap_envelope(rm_msg_ctx->terminate_seq, env, soap_envelope);
    }
    if(rm_msg_ctx->terminate_seq_res)
    {
        sandesha2_terminate_seq_res_to_soap_envelope(rm_msg_ctx->terminate_seq_res, env, soap_envelope);
    }
    return AXIS2_SUCCESS;
}
            
int AXIS2_CALL
sandesha2_msg_ctx_get_msg_type (
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->msg_type;
}
            
axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_msg_type (
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, int msg_type)
{
    rm_msg_ctx->msg_type = msg_type;
    return AXIS2_SUCCESS;
}
                          
axis2_endpoint_ref_t *AXIS2_CALL
sandesha2_msg_ctx_get_from(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return axis2_msg_ctx_get_from(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_from(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, 
    axis2_endpoint_ref_t *from)
{
    AXIS2_PARAM_CHECK(env->error, from, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_from(rm_msg_ctx->msg_ctx, env, from);;
}
    
axis2_endpoint_ref_t *AXIS2_CALL
sandesha2_msg_ctx_get_to (
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env)
{
    return axis2_msg_ctx_get_to(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_to(
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env, 
    axis2_endpoint_ref_t *to)
{
    AXIS2_PARAM_CHECK(env->error, to, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_to(rm_msg_ctx->msg_ctx, env, to);
}
    
axis2_endpoint_ref_t *AXIS2_CALL
sandesha2_msg_ctx_get_reply_to(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return axis2_msg_ctx_get_reply_to(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_reply_to(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, axis2_endpoint_ref_t *reply_to)
{
    AXIS2_PARAM_CHECK(env->error, reply_to, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_reply_to(rm_msg_ctx->msg_ctx, env, reply_to);
}
    
axis2_endpoint_ref_t *AXIS2_CALL
sandesha2_msg_ctx_get_fault_to(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return axis2_msg_ctx_get_fault_to(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_fault_to(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, axis2_endpoint_ref_t *fault_to)
{
    AXIS2_PARAM_CHECK(env->error, fault_to, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_fault_to(rm_msg_ctx->msg_ctx, env, fault_to);
}
    
axis2_relates_to_t *AXIS2_CALL
sandesha2_msg_ctx_get_relates_to(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return axis2_msg_ctx_get_relates_to(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_relates_to(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, axis2_relates_to_t *relates_to)
{
    AXIS2_PARAM_CHECK(env->error, relates_to, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_relates_to(rm_msg_ctx->msg_ctx, env, relates_to);
}
    
axis2_char_t *AXIS2_CALL
sandesha2_msg_ctx_get_msg_id(
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env)
{
    return (axis2_char_t*)axis2_msg_ctx_get_wsa_message_id(
                        rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_msg_id(
    sandesha2_msg_ctx_t *rm_msg_ctx, 
    const axutil_env_t *env, 
    axis2_char_t *msg_id)
{
    AXIS2_PARAM_CHECK(env->error, msg_id, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_message_id(rm_msg_ctx->msg_ctx, env, msg_id);
}
    
axiom_soap_envelope_t *AXIS2_CALL
sandesha2_msg_ctx_get_soap_envelope(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return axis2_msg_ctx_get_soap_envelope(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_soap_envelope(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, 
    axiom_soap_envelope_t *soap_envelope)
{
    AXIS2_PARAM_CHECK(env->error, soap_envelope, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_soap_envelope(rm_msg_ctx->msg_ctx, env, 
                        soap_envelope);
}
            
axis2_char_t *AXIS2_CALL
sandesha2_msg_ctx_get_wsa_action(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return (axis2_char_t*)axis2_msg_ctx_get_wsa_action(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_wsa_action(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, axis2_char_t *action)
{
    AXIS2_PARAM_CHECK(env->error, action, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_wsa_action(rm_msg_ctx->msg_ctx, env, action);
}
            
void *AXIS2_CALL
sandesha2_msg_ctx_get_property(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, axis2_char_t *key)
{
    AXIS2_PARAM_CHECK(env->error, key, NULL);
    
    return axis2_msg_ctx_get_property(rm_msg_ctx->msg_ctx, env, key);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_property(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, 
    axis2_char_t *key, 
    void *val)
{
    AXIS2_PARAM_CHECK(env->error, key, AXIS2_FAILURE);
    
    return axis2_msg_ctx_set_property(rm_msg_ctx->msg_ctx, env, key, val);
}
    
axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_soap_action(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, 
    axutil_string_t *soap_action)
{
    AXIS2_PARAM_CHECK(env->error, soap_action, AXIS2_FAILURE);
    
    if(NULL == rm_msg_ctx->msg_ctx)
        return AXIS2_FAILURE;
    
    return axis2_msg_ctx_set_soap_action(rm_msg_ctx->msg_ctx, env, 
        soap_action);
}
    
axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_paused(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, 
    axis2_bool_t paused)
{
    if(NULL == rm_msg_ctx->msg_ctx)
        return AXIS2_FAILURE;
    return axis2_msg_ctx_set_paused(rm_msg_ctx->msg_ctx, env, paused);    
}
    
axis2_char_t *AXIS2_CALL
sandesha2_msg_ctx_get_rm_ns_val(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->rm_ns_val;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_rm_ns_val(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, 
    axis2_char_t *ns_val)
{
    AXIS2_PARAM_CHECK(env->error, ns_val, AXIS2_FAILURE);
    
    if(NULL != rm_msg_ctx->rm_ns_val)
    {
        AXIS2_FREE(env->allocator, rm_msg_ctx->rm_ns_val);
        rm_msg_ctx->rm_ns_val = NULL;
    }
    rm_msg_ctx->rm_ns_val = axutil_strdup(env, ns_val);
    if(0 == axutil_strcmp(ns_val, SANDESHA2_SPEC_2005_02_NS_URI))
        rm_msg_ctx->spec_ver = axutil_strdup(env, SANDESHA2_SPEC_VERSION_1_0);
    if(0 == axutil_strcmp(ns_val, SANDESHA2_SPEC_2007_02_NS_URI))
        rm_msg_ctx->spec_ver = axutil_strdup(env, SANDESHA2_SPEC_VERSION_1_1);
        
    return AXIS2_SUCCESS;
}
    
axis2_char_t *AXIS2_CALL
sandesha2_msg_ctx_get_addr_ns_val(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->addr_ns_val;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_addr_ns_val(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, axis2_char_t *ns_val)
{
    AXIS2_PARAM_CHECK(env->error, ns_val, AXIS2_FAILURE);
    
    if(NULL != rm_msg_ctx->addr_ns_val)
    {
        AXIS2_FREE(env->allocator, rm_msg_ctx->addr_ns_val);
        rm_msg_ctx->addr_ns_val = NULL;
    }
    rm_msg_ctx->addr_ns_val = axutil_strdup(env, ns_val);
    return AXIS2_SUCCESS;
}
            
int AXIS2_CALL
sandesha2_msg_ctx_get_flow(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    if(NULL == rm_msg_ctx->msg_ctx)
        return -1;
    return axis2_msg_ctx_get_flow(rm_msg_ctx->msg_ctx, env);     
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_flow(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env, int flow)
{
    if(NULL == rm_msg_ctx->msg_ctx)
        return AXIS2_FAILURE;
        
    return axis2_msg_ctx_set_flow(rm_msg_ctx->msg_ctx, env, flow); 
}

axis2_char_t *AXIS2_CALL
sandesha2_msg_ctx_get_rm_spec_ver(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->spec_ver;
}

AXIS2_EXTERN axutil_stream_t *AXIS2_CALL
sandesha2_msg_ctx_get_transport_out_stream(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    if(!rm_msg_ctx->msg_ctx)
        return NULL;
    return axis2_msg_ctx_get_transport_out_stream(rm_msg_ctx->msg_ctx, env);
}

AXIS2_EXTERN axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_transport_out_stream(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    axutil_stream_t *stream)
{
    if(!rm_msg_ctx->msg_ctx)
        return AXIS2_FAILURE;
    return axis2_msg_ctx_set_transport_out_stream(rm_msg_ctx->msg_ctx, env, 
        stream);
}

AXIS2_EXTERN struct axis2_out_transport_info *AXIS2_CALL
sandesha2_msg_ctx_get_out_transport_info(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    if(!rm_msg_ctx->msg_ctx)
        return NULL;
    return axis2_msg_ctx_get_out_transport_info(rm_msg_ctx->msg_ctx, env);
}

AXIS2_EXTERN axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_out_transport_info(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    struct axis2_out_transport_info *out_transport_info)
{
    if(!rm_msg_ctx->msg_ctx)
        return AXIS2_FAILURE;
    return axis2_msg_ctx_set_out_transport_info(rm_msg_ctx->msg_ctx, 
        env, out_transport_info);
}

AXIS2_EXTERN axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_reset_out_transport_info(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    if(!rm_msg_ctx->msg_ctx)
        return AXIS2_FAILURE;
    return axis2_msg_ctx_reset_out_transport_info(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_create_seq(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_create_seq_t *create_seq)
{
    AXIS2_PARAM_CHECK(env->error, create_seq, AXIS2_FAILURE);
    
    rm_msg_ctx->create_seq = create_seq;
    return AXIS2_SUCCESS;
}
 
sandesha2_create_seq_t *AXIS2_CALL
sandesha2_msg_ctx_get_create_seq(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->create_seq;
}
 
axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_create_seq_res(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_create_seq_res_t *create_seq_res)
{
    AXIS2_PARAM_CHECK(env->error, create_seq_res, AXIS2_FAILURE);
   
    if(rm_msg_ctx->create_seq_res)
    {
        sandesha2_create_seq_res_free(rm_msg_ctx->create_seq_res, env);
        rm_msg_ctx->create_seq_res = NULL;
    }

    rm_msg_ctx->create_seq_res = create_seq_res;
    return AXIS2_SUCCESS;
}
 
sandesha2_create_seq_res_t *AXIS2_CALL
sandesha2_msg_ctx_get_create_seq_res(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->create_seq_res;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_close_seq(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_close_seq_t *close_seq)
{
    AXIS2_PARAM_CHECK(env->error, close_seq, AXIS2_FAILURE);
    
    rm_msg_ctx->close_seq = close_seq;
    return AXIS2_SUCCESS;
}
 
sandesha2_close_seq_t *AXIS2_CALL
sandesha2_msg_ctx_get_close_seq(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->close_seq;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_close_seq_res(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_close_seq_res_t *close_seq_res)
{
    AXIS2_PARAM_CHECK(env->error, close_seq_res, AXIS2_FAILURE);
    
    rm_msg_ctx->close_seq_res = close_seq_res;
    return AXIS2_SUCCESS;
}
 
sandesha2_close_seq_res_t *AXIS2_CALL
sandesha2_msg_ctx_get_close_seq_res(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->close_seq_res;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_terminate_seq(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_terminate_seq_t *terminate_seq)
{
    AXIS2_PARAM_CHECK(env->error, terminate_seq, AXIS2_FAILURE);
    
    rm_msg_ctx->terminate_seq = terminate_seq;
    return AXIS2_SUCCESS;
}
 
sandesha2_terminate_seq_t *AXIS2_CALL
sandesha2_msg_ctx_get_terminate_seq(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->terminate_seq;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_terminate_seq_res(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_terminate_seq_res_t *terminate_seq_res)
{
    AXIS2_PARAM_CHECK(env->error, terminate_seq_res, AXIS2_FAILURE);
    
    rm_msg_ctx->terminate_seq_res = terminate_seq_res;
    return AXIS2_SUCCESS;
}
 
sandesha2_terminate_seq_res_t *AXIS2_CALL
sandesha2_msg_ctx_get_terminate_seq_res(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->terminate_seq_res;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_make_connection(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_make_connection_t *make_connection)
{
    AXIS2_PARAM_CHECK(env->error, make_connection, AXIS2_FAILURE);
    
    rm_msg_ctx->make_connection = make_connection;
    return AXIS2_SUCCESS;
}
 
sandesha2_make_connection_t *AXIS2_CALL
sandesha2_msg_ctx_get_make_connection(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->make_connection;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_msg_pending(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_msg_pending_t *msg_pending)
{
    AXIS2_PARAM_CHECK(env->error, msg_pending, AXIS2_FAILURE);
    
    rm_msg_ctx->msg_pending = msg_pending;
    return AXIS2_SUCCESS;
}
 
sandesha2_msg_pending_t *AXIS2_CALL
sandesha2_msg_ctx_get_msg_pending(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->msg_pending;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_sequence(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_seq_t *seq)
{
    AXIS2_PARAM_CHECK(env->error, seq, AXIS2_FAILURE);
    
    rm_msg_ctx->seq = seq;
    return AXIS2_SUCCESS;
}
 
sandesha2_seq_t *AXIS2_CALL
sandesha2_msg_ctx_get_sequence(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->seq;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_seq_ack(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_seq_ack_t *seq_ack)
{
    AXIS2_PARAM_CHECK(env->error, seq_ack, AXIS2_FAILURE);
    
    rm_msg_ctx->seq_ack = seq_ack;
    return AXIS2_SUCCESS;
}
 
sandesha2_seq_ack_t *AXIS2_CALL
sandesha2_msg_ctx_get_seq_ack(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->seq_ack;
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_ack_requested(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env,
    sandesha2_ack_requested_t *ack_requested)
{
    AXIS2_PARAM_CHECK(env->error, ack_requested, AXIS2_FAILURE);
    
    rm_msg_ctx->ack_requested = ack_requested;
    return AXIS2_SUCCESS;
}
 
sandesha2_ack_requested_t *AXIS2_CALL
sandesha2_msg_ctx_get_ack_requested(
    sandesha2_msg_ctx_t *rm_msg_ctx,
    const axutil_env_t *env)
{
    return rm_msg_ctx->ack_requested;
}

axis2_bool_t AXIS2_CALL
sandesha2_msg_ctx_get_server_side(
    const sandesha2_msg_ctx_t * rm_msg_ctx,
    const axutil_env_t * env)
{
    return axis2_msg_ctx_get_server_side(rm_msg_ctx->msg_ctx, env);
}

axis2_status_t AXIS2_CALL
sandesha2_msg_ctx_set_server_side(
    const sandesha2_msg_ctx_t * rm_msg_ctx,
    const axutil_env_t * env,
    const axis2_bool_t server_side)
{
    return axis2_msg_ctx_set_server_side(rm_msg_ctx->msg_ctx, env, server_side);
}