Amazon-SQS-Client

 view release on metacpan or  search on metacpan

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

sub _getFormattedTimestamp {
  return sprintf '%04d-%02d-%02dT%02d:%02d:%02d.000Z', sub {
    ( $_[5] + 1900, $_[4] + 1, $_[3], $_[2], $_[1], $_[0] )
    }
    ->( gmtime time );
}

#
# Convert CreateQueueRequest to name value pairs
#
sub _convertCreateQueue() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'CreateQueue';

  if ( $request->isSetQueueName() ) {
    $parameters->{'QueueName'} = $request->getQueueName();
  }

  if ( $request->isSetDefaultVisibilityTimeout() ) {

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

        = $attributecreateQueueRequest->getValue();
    }
  }

  return $parameters;
}

#
# Convert ListQueuesRequest to name value pairs
#
sub _convertListQueues() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'ListQueues';

  if ( $request->isSetQueueNamePrefix() ) {
    $parameters->{'QueueNamePrefix'} = $request->getQueueNamePrefix();
  }
  my $attributelistQueuesRequestList = $request->getAttribute();

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    }

  }

  return $parameters;
}

#
# Convert ListDeadLetterSourceQueues to name value pairs
#
sub _convertListDeadLetterSourceQueues() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'ListDeadLetterSourceQueues';

  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }

  return $parameters;
}

#
# Convert ChangeMessageVisibilityRequest to name value pairs
#
sub _convertChangeMessageVisibility() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'ChangeMessageVisibility';

  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }

  if ( $request->isSetReceiptHandle() ) {

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    if ( $attributechangeMessageVisibilityRequest->isSetValue() ) {
      $parameters->{ 'Attribute.' . ( $attributechangeMessageVisibilityRequestIndex + 1 ) . '.Value' }
        = $attributechangeMessageVisibilityRequest->getValue();
    }
  }

  return $parameters;
}

sub _convertChangeMessageVisibilityBatch() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'ChangeMessageVisibilityBatch';

  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }

  if ( $request->isSetBatchRequest() ) {

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

      }
    }
  }

  return $parameters;
}

#
# Convert DeleteMessageRequest to name value pairs
#
sub _convertDeleteMessage() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'DeleteMessage';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }
  if ( $request->isSetReceiptHandle() ) {
    $parameters->{ReceiptHandle} = $request->getReceiptHandle();
  }

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    if ( $attributedeleteMessageRequest->isSetValue() ) {
      $parameters->{ 'Attribute.' . ( $attributedeleteMessageRequestIndex + 1 ) . '.Value' }
        = $attributedeleteMessageRequest->getValue();
    }

  }

  return $parameters;
}

sub _convertDeleteMessageBatch() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'DeleteMessageBatch';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }

  if ( $request->isSetDeleteMessageBatchRequestEntry() ) {
    my $batchrequestList = $request->getDeleteMessageBatchRequestEntry();

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

      }
    }
  }

  return $parameters;
}

#
# Convert DeleteQueueRequest to name value pairs
#
sub _convertDeleteQueue() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'DeleteQueue';

  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }
  my $attributedeleteQueueRequestList = $request->getAttribute();
  for my $attributedeleteQueueRequestIndex ( 0 .. $#{$attributedeleteQueueRequestList} ) {

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    }

  }

  return $parameters;
}

#
# Convert GetQueueAttributesRequest to name value pairs
#
sub _convertGetQueueAttributes() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'GetQueueAttributes';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }
  my $attributeNamegetQueueAttributesRequestList = $request->getAttributeName();
  for my $attributeNamegetQueueAttributesRequestIndex ( 0 .. $#{$attributeNamegetQueueAttributesRequestList} ) {
    my $attributeNamegetQueueAttributesRequest

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    $parameters->{ 'AttributeName.' . ( $attributeNamegetQueueAttributesRequestIndex + 1 ) }
      = $attributeNamegetQueueAttributesRequest;
  }

  return $parameters;
}

#
# Convert ReceiveMessageRequest to name value pairs
#
sub _convertReceiveMessage() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'ReceiveMessage';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }
  if ( $request->isSetMaxNumberOfMessages() ) {
    $parameters->{MaxNumberOfMessages} = $request->getMaxNumberOfMessages();
  }

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    $parameters->{ 'MessageAttributeName.' . ( $messageAttributeNamereceiveMessageRequestIndex + 1 ) }
      = $messageAttributeNamereceiveMessageRequest;
  }

  return $parameters;
}

#
# Convert SendMessageRequest to name value pairs
#
sub _convertSendMessage() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'SendMessage';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }

  if ( $request->isSetMessageBody() ) {
    $parameters->{MessageBody} = $request->getMessageBody();

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

        = $value->getBinaryValue();
    }
  }

  return $parameters;
}

#
# Convert SetQueueAttributesRequest to name value pairs
#
sub _convertSetQueueAttributes() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'SetQueueAttributes';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }
  my $attributesetQueueAttributesRequestList = $request->getAttribute();
  for my $attributesetQueueAttributesRequestIndex ( 0 .. $#{$attributesetQueueAttributesRequestList} ) {
    my $attributesetQueueAttributesRequest

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    }

  }

  return $parameters;
}

#
# Convert AddPermissionRequest to name value pairs
#
sub _convertAddPermission() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'AddPermission';

  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }

  if ( $request->isSetLabel() ) {

lib/Amazon/SQS/Client.pm  view on Meta::CPAN

    $parameters->{ 'ActionName.' . ( $actionNameaddPermissionRequestIndex + 1 ) }
      = $actionNameaddPermissionRequest;
  }

  return $parameters;
}

#
# Convert RemovePermissionRequest to name value pairs
#
sub _convertRemovePermission() {
  my ( $self, $request ) = @_;

  my $parameters = {};
  $parameters->{Action} = 'RemovePermission';
  if ( $request->isSetQueueUrl() ) {
    $parameters->{QueueUrl} = $request->getQueueUrl();
  }
  if ( $request->isSetLabel() ) {
    $parameters->{Label} = $request->getLabel();
  }