#!/usr/bin/env python

import time
from qclient import connect, Thrift
import sys, os.path
sys.path.insert(0, os.path.join(os.path.abspath(os.path.split(sys.argv[0])[0]), '..', 'gen-py'))
import simplequeue.SQueue
from simplequeue.ttypes import *
from thrift import Thrift
from TSqsClient import TSqsClient
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol

transport = TSqsClient("<accessKey>", "<secretAccessKey>", '<queueName>')
transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = simplequeue.SQueue.Client(protocol)
transport.open()

for i in range(1000):
  client.push("testing #%d - %d" % (i, time.time()))
  time.sleep(1)