77
88 amqp "github.com/rabbitmq/amqp091-go"
99 "github.com/senzing-garage/go-helpers/record"
10- "github.com/senzing-garage/sz-sdk-go/sz "
10+ "github.com/senzing-garage/sz-sdk-go/senzing "
1111 "github.com/sourcegraph/conc/pool"
1212)
1313
@@ -20,7 +20,7 @@ var jobPool chan *RabbitConsumerJob
2020// define a structure that will implement the Job interface
2121type RabbitConsumerJob struct {
2222 delivery amqp.Delivery
23- engine * sz .SzEngine
23+ engine * senzing .SzEngine
2424 id int
2525 usedCount int
2626 withInfo bool
@@ -39,9 +39,9 @@ func (j *RabbitConsumerJob) Execute(ctx context.Context) error {
3939 // fmt.Printf("Received a message- msgId: %s, msgCnt: %d, ConsumerTag: %s\n", id, j.delivery.MessageCount, j.delivery.ConsumerTag)
4040 record , newRecordErr := record .NewRecord (string (j .delivery .Body ))
4141 if newRecordErr == nil {
42- flags := sz . SZ_WITHOUT_INFO
42+ flags := senzing . SzWithoutInfo
4343 if j .withInfo {
44- flags = sz . SZ_WITH_INFO
44+ flags = senzing . SzWithInfo
4545 }
4646 result , err := (* j .engine ).AddRecord (ctx , record .DataSource , record .ID , record .JSON , flags )
4747 if err != nil {
@@ -78,7 +78,7 @@ func (j *RabbitConsumerJob) OnError(err error) {
7878// them to Senzing.
7979// - Workers restart when they are killed or die.
8080// - respond to standard system signals.
81- func StartManagedConsumer (ctx context.Context , urlString string , numberOfWorkers int , szEngine * sz .SzEngine , withInfo bool , logLevel string , jsonOutput bool ) error {
81+ func StartManagedConsumer (ctx context.Context , urlString string , numberOfWorkers int , szEngine * senzing .SzEngine , withInfo bool , logLevel string , jsonOutput bool ) error {
8282 _ = jsonOutput
8383
8484 // default to the max number of OS threads
0 commit comments