$connecting++;
}
- if( $payload ) {
- $logger->debug( "Payload is ".$payload->toString, INTERNAL );
- }
-
-
my $msg = OpenSRF::DomainObject::oilsMessage->new();
- $logger->debug( "AppSession after creating oilsMessage $msg", INTERNAL );
-
$msg->type($msg_type);
- $logger->debug( "AppSession after adding type" . $msg->toString(), INTERNAL );
-
- #$msg->userAuth($self->client_auth) if ($self->endpoint == CLIENT && $msg_type eq 'CONNECT');
no warnings;
$msg->threadTrace( $tT || int($self->session_threadTrace) || int($self->last_threadTrace) );
#return; eventually...
}
push @{ $self->{recv_queue} }, $resp;
- OpenSRF::Utils::Logger->debug( "AppRequest pushed ".$resp->toString(), INTERNAL );
}
sub failed {
sub resend {
my $self = shift;
return unless ($self and $self->session and !$self->complete);
- OpenSRF::Utils::Logger->debug(
- "I'm resending the request for threadTrace ". $self->threadTrace, DEBUG);
- if($self->payload) {
- OpenSRF::Utils::Logger->debug($self->payload->toString,INTERNAL);
- }
+ OpenSRF::Utils::Logger->debug( "I'm resending the request for threadTrace ". $self->threadTrace, DEBUG);
return $self->session->send('REQUEST', $self->payload, $self->threadTrace );
}
if( $app ) {
$log->debug( "Application is $app", DEBUG);
}
- $log->debug( "Message is ".$app_msg->toString(1), INTERNAL);
-
if ($session->last_message_type eq 'REQUEST') {
$log->debug( "We got a REQUEST: ". $app_msg->method, INFO );
my $time = sprintf '%.3f', time() - $start;
$log->debug( "Method duration for {$method_name -> ".join(', ', @args)."}: ". $time, DEBUG );
if( defined( $resp ) ) {
- #$log->debug( "Calling respond_complete: ". $resp->toString(), INTERNAL );
$appreq->respond_complete( $resp );
} else {
$appreq->status( OpenSRF::DomainObject::oilsConnectStatus->new(
$appreq = $aref->[0];
if( ref( $response ) ) {
- #$log->debug( "Calling respond_complete: ". $response->toString(), INTERNAL );
$appreq->respond_complete( $response );
} else {
$appreq->status( OpenSRF::DomainObject::oilsConnectStatus->new(
return 1;
} else {
- $log->debug( "Pushing ". $app_msg->toString ." onto queue", INTERNAL );
$session->push_queue([ $app_msg, $session->last_threadTrace ]);
}
$log->debug("Passing to Application::handler()", INFO);
- $log->debug($self->toString(1), DEBUG);
return 1;
$self->payload->throw();
}
- if( $self->payload ) {
- $log->debug("Passing to OpenSRF::Application::handler()\n" . $self->payload->toString(1), INTERNAL);
- }
$log->debug("oilsMessage passing to Application: " . $self->type." : ".$session->remote_id, INFO );
return 1;
}
sub new {
- my $name = shift;
- $name = ref($class) || $class;
+ my $class = shift;
+ $class = ref($class) || $class;
my $default_status = eval "\$${class}::status";
my $default_statusCode = eval "\$${class}::statusCode";
}
sub new {
- my $name = shift;
+ my $class = shift;
return $class->OpenSRF::DomainObject::oilsResponse::new( @_ );
}
# up to the message layer for processing.
for my $msg (@$doc) {
- $logger->transport(
- "Transport::handler()passing to message handler \n".$msg->toString(1), DEBUG );
+ $logger->transport( "Transport::handler()passing to message handler", DEBUG );
- $logger->transport(
- "Transport passing up ".$msg->type." from ".
+ $logger->transport( "Transport passing up ".$msg->type." from ".
$app_session->remote_id . " with threadTrace [" . $msg->threadTrace."]", INFO );
next unless ( $msg && UNIVERSAL::isa($msg => 'OpenSRF::DomainObject::oilsMessage'));