Skip to content

Commit 39a3642

Browse files
Artemyev VyacheslavArtemyev Vyacheslav
Artemyev Vyacheslav
authored and
Artemyev Vyacheslav
committed
Rename package
1 parent 3d0e6c2 commit 39a3642

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

42 files changed

+98
-167
lines changed

‎benchmarks/src/jmh/kotlin/com/github/viartemev/rabbitmq/ConfirmPublisherBenchmark.kt renamed to ‎benchmarks/src/jmh/kotlin/io/github/viartemev/rabbitmq/ConfirmPublisherBenchmark.kt

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package com.github.viartemev.rabbitmq
1+
package io.github.viartemev.rabbitmq
22

3-
import com.github.viartemev.rabbitmq.channel.ConfirmChannel
4-
import com.github.viartemev.rabbitmq.channel.createConfirmChannel
5-
import com.github.viartemev.rabbitmq.publisher.ConfirmPublisher
6-
import com.github.viartemev.rabbitmq.publisher.OutboundMessage
73
import com.rabbitmq.client.Connection
84
import com.rabbitmq.client.ConnectionFactory
95
import com.rabbitmq.client.MessageProperties
6+
import io.github.viartemev.rabbitmq.channel.ConfirmChannel
7+
import io.github.viartemev.rabbitmq.channel.createConfirmChannel
8+
import io.github.viartemev.rabbitmq.publisher.ConfirmPublisher
9+
import io.github.viartemev.rabbitmq.publisher.OutboundMessage
1010
import kotlinx.coroutines.Dispatchers
1111
import kotlinx.coroutines.async
1212
import kotlinx.coroutines.awaitAll

‎build.gradle

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ plugins {
3131
}
3232

3333
allprojects {
34-
group = "com.viartemev"
34+
group = "io.github.viartemev"
3535

3636
apply plugin: "java"
3737
apply plugin: "kotlin"

‎rabbitmq-kotlin-example/src/main/kotlin/com/github/viartemev/rabbitmq/example/ConsumerExample.kt renamed to ‎rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/ConsumerExample.kt

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.github.viartemev.rabbitmq.example
1+
package io.github.viartemev.rabbitmq.example
22

3-
import com.github.viartemev.rabbitmq.channel.channel
4-
import com.github.viartemev.rabbitmq.channel.consume
53
import com.rabbitmq.client.ConnectionFactory
64
import com.rabbitmq.client.Delivery
5+
import io.github.viartemev.rabbitmq.channel.channel
6+
import io.github.viartemev.rabbitmq.channel.consume
77
import kotlinx.coroutines.Dispatchers
88
import kotlinx.coroutines.async
99
import kotlinx.coroutines.awaitAll

‎rabbitmq-kotlin-example/src/main/kotlin/com/github/viartemev/rabbitmq/example/PublisherExample.kt renamed to ‎rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/PublisherExample.kt

+7-9
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,13 @@
1-
package com.github.viartemev.rabbitmq.example
1+
package io.github.viartemev.rabbitmq.example
22

3-
import com.github.viartemev.rabbitmq.channel.confirmChannel
4-
import com.github.viartemev.rabbitmq.channel.publish
5-
import com.github.viartemev.rabbitmq.publisher.OutboundMessage
6-
import com.github.viartemev.rabbitmq.queue.QueueSpecification
7-
import com.github.viartemev.rabbitmq.queue.declareQueue
83
import com.rabbitmq.client.ConnectionFactory
94
import com.rabbitmq.client.MessageProperties
10-
import kotlinx.coroutines.awaitAll
11-
import kotlinx.coroutines.coroutineScope
12-
import kotlinx.coroutines.runBlocking
5+
import io.github.viartemev.rabbitmq.channel.confirmChannel
6+
import io.github.viartemev.rabbitmq.channel.publish
7+
import io.github.viartemev.rabbitmq.publisher.OutboundMessage
8+
import io.github.viartemev.rabbitmq.queue.QueueSpecification
9+
import io.github.viartemev.rabbitmq.queue.declareQueue
10+
import kotlinx.coroutines.*
1311

1412
const val PUBLISHER_EXCHANGE_NAME = ""
1513
const val PUBLISHER_QUEUE_NAME = "test_queue"

‎rabbitmq-kotlin-example/src/main/kotlin/com/github/viartemev/rabbitmq/example/rpc/RpcClient.kt renamed to ‎rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/rpc/RpcClient.kt

+4-4
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
package com.github.viartemev.rabbitmq.example.rpc
1+
package io.github.viartemev.rabbitmq.example.rpc
22

3-
import com.github.viartemev.rabbitmq.channel.channel
4-
import com.github.viartemev.rabbitmq.channel.rpc
5-
import com.github.viartemev.rabbitmq.publisher.OutboundMessage
63
import com.rabbitmq.client.ConnectionFactory
74
import com.rabbitmq.client.MessageProperties
5+
import io.github.viartemev.rabbitmq.channel.channel
6+
import io.github.viartemev.rabbitmq.channel.rpc
7+
import io.github.viartemev.rabbitmq.publisher.OutboundMessage
88
import kotlinx.coroutines.Dispatchers
99
import kotlinx.coroutines.async
1010
import kotlinx.coroutines.runBlocking

‎rabbitmq-kotlin-example/src/main/kotlin/com/github/viartemev/rabbitmq/example/rpc/RpcServer.kt renamed to ‎rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/rpc/RpcServer.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.example.rpc
1+
package io.github.viartemev.rabbitmq.example.rpc
22

33
import com.rabbitmq.client.AMQP
44
import com.rabbitmq.client.ConnectionFactory

‎src/main/kotlin/com/github/viartemev/rabbitmq/channel/Channel.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/channel/Channel.kt

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.github.viartemev.rabbitmq.channel
1+
package io.github.viartemev.rabbitmq.channel
22

3-
import com.github.viartemev.rabbitmq.consumer.ConfirmConsumer
4-
import com.github.viartemev.rabbitmq.rpc.RpcClient
53
import com.rabbitmq.client.Channel
64
import com.rabbitmq.client.Delivery
5+
import io.github.viartemev.rabbitmq.consumer.ConfirmConsumer
6+
import io.github.viartemev.rabbitmq.rpc.RpcClient
77

88
/**
99
* Creates a ConfirmConsumer for the given Channel, queue, and prefetchSize.

‎src/main/kotlin/com/github/viartemev/rabbitmq/channel/Channels.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/channel/Channels.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.channel
1+
package io.github.viartemev.rabbitmq.channel
22

33
import com.rabbitmq.client.Channel
44
import java.util.concurrent.ConcurrentHashMap

‎src/main/kotlin/com/github/viartemev/rabbitmq/channel/ConfirmChannel.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/channel/ConfirmChannel.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
package com.github.viartemev.rabbitmq.channel
1+
package io.github.viartemev.rabbitmq.channel
22

3-
import com.github.viartemev.rabbitmq.publisher.ConfirmPublisher
43
import com.rabbitmq.client.Channel
4+
import io.github.viartemev.rabbitmq.publisher.ConfirmPublisher
55

66
/**
77
* A helper class for confirming messages sent through a channel.

‎src/main/kotlin/com/github/viartemev/rabbitmq/channel/Connection.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/channel/Connection.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.channel
1+
package io.github.viartemev.rabbitmq.channel
22

33
import com.rabbitmq.client.Channel
44
import com.rabbitmq.client.Connection

‎src/main/kotlin/com/github/viartemev/rabbitmq/channel/TxChannel.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/channel/TxChannel.kt

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package com.github.viartemev.rabbitmq.channel
1+
package io.github.viartemev.rabbitmq.channel
22

3-
import com.github.viartemev.rabbitmq.consumer.ConfirmConsumer
4-
import com.github.viartemev.rabbitmq.publisher.OutboundMessage
53
import com.rabbitmq.client.Channel
4+
import io.github.viartemev.rabbitmq.consumer.ConfirmConsumer
5+
import io.github.viartemev.rabbitmq.publisher.OutboundMessage
66
import mu.KotlinLogging
77
import java.util.concurrent.atomic.AtomicBoolean
88

‎src/main/kotlin/com/github/viartemev/rabbitmq/consumer/ConfirmConsumer.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/consumer/ConfirmConsumer.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.consumer
1+
package io.github.viartemev.rabbitmq.consumer
22

33
import com.rabbitmq.client.Channel
44
import com.rabbitmq.client.Delivery

‎src/main/kotlin/com/github/viartemev/rabbitmq/consumer/flow/ConsumerFlow.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/consumer/flow/ConsumerFlow.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.consumer.flow
1+
package io.github.viartemev.rabbitmq.consumer.flow
22

33
import com.rabbitmq.client.Channel
44
import com.rabbitmq.client.Delivery

‎src/main/kotlin/com/github/viartemev/rabbitmq/exchange/BindExchangeSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/exchange/BindExchangeSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

33
/**
44
* Represents the specification for binding an exchange to a destination with optional arguments.

‎src/main/kotlin/com/github/viartemev/rabbitmq/exchange/DeleteExchangeSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/exchange/DeleteExchangeSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

33
/**
44
* Represents a specification for deleting an exchange.

‎src/main/kotlin/com/github/viartemev/rabbitmq/exchange/Exchange.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/exchange/Exchange.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

33
import com.rabbitmq.client.AMQP
44
import com.rabbitmq.client.Channel

‎src/main/kotlin/com/github/viartemev/rabbitmq/exchange/ExchangeSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/exchange/ExchangeSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

33
/**
44
* Represents the specification of an exchange in a messaging system.

‎src/main/kotlin/com/github/viartemev/rabbitmq/exchange/ExchangeType.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/exchange/ExchangeType.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

33
/**
44
* Represents the type of exchange in a messaging system.

‎src/main/kotlin/com/github/viartemev/rabbitmq/exchange/UnbindExchangeSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/exchange/UnbindExchangeSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

33
/**
44
* Represents the specification for unbinding an exchange from a queue.

‎src/main/kotlin/com/github/viartemev/rabbitmq/publisher/AckListener.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/publisher/AckListener.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.publisher
1+
package io.github.viartemev.rabbitmq.publisher
22

33
import com.rabbitmq.client.ConfirmListener
44
import mu.KotlinLogging

‎src/main/kotlin/com/github/viartemev/rabbitmq/publisher/ConfirmPublisher.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/publisher/ConfirmPublisher.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.publisher
1+
package io.github.viartemev.rabbitmq.publisher
22

33
import com.rabbitmq.client.Channel
44
import kotlinx.coroutines.suspendCancellableCoroutine

‎src/main/kotlin/com/github/viartemev/rabbitmq/publisher/OutboundMessage.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/publisher/OutboundMessage.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.publisher
1+
package io.github.viartemev.rabbitmq.publisher
22

33
import com.rabbitmq.client.AMQP.BasicProperties
44

‎src/main/kotlin/com/github/viartemev/rabbitmq/queue/BindQueueSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/queue/BindQueueSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.queue
1+
package io.github.viartemev.rabbitmq.queue
22

33
/**
44
* Represents the specifications for binding a queue to an exchange.

‎src/main/kotlin/com/github/viartemev/rabbitmq/queue/DeleteQueueSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/queue/DeleteQueueSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.queue
1+
package io.github.viartemev.rabbitmq.queue
22

33
/**
44
* Represents the specifications for deleting a queue.

‎src/main/kotlin/com/github/viartemev/rabbitmq/queue/PurgeQueueSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/queue/PurgeQueueSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.queue
1+
package io.github.viartemev.rabbitmq.queue
22

33
/**
44
* Represents a specification for purging a queue.

‎src/main/kotlin/com/github/viartemev/rabbitmq/queue/Queue.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/queue/Queue.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.queue
1+
package io.github.viartemev.rabbitmq.queue
22

33
import com.rabbitmq.client.AMQP
44
import com.rabbitmq.client.Channel

‎src/main/kotlin/com/github/viartemev/rabbitmq/queue/QueueSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/queue/QueueSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.queue
1+
package io.github.viartemev.rabbitmq.queue
22

33
/**
44
* Represents the specification of a queue in a message broker.

‎src/main/kotlin/com/github/viartemev/rabbitmq/queue/UnbindQueueSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/queue/UnbindQueueSpecification.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.github.viartemev.rabbitmq.queue
1+
package io.github.viartemev.rabbitmq.queue
22

33
/**
44
* Represents the specifications for unbinding a queue from an exchange.

‎src/main/kotlin/com/github/viartemev/rabbitmq/rpc/RpcClient.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/rpc/RpcClient.kt

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
package com.github.viartemev.rabbitmq.rpc
1+
package io.github.viartemev.rabbitmq.rpc
22

3-
import com.github.viartemev.rabbitmq.publisher.OutboundMessage
4-
import com.github.viartemev.rabbitmq.queue.DeleteQueueSpecification
5-
import com.github.viartemev.rabbitmq.queue.declareQueue
6-
import com.github.viartemev.rabbitmq.queue.deleteQueue
73
import com.rabbitmq.client.Channel
84
import com.rabbitmq.client.Delivery
5+
import io.github.viartemev.rabbitmq.publisher.OutboundMessage
6+
import io.github.viartemev.rabbitmq.queue.DeleteQueueSpecification
7+
import io.github.viartemev.rabbitmq.queue.declareQueue
8+
import io.github.viartemev.rabbitmq.queue.deleteQueue
99
import kotlinx.coroutines.Dispatchers
1010
import kotlinx.coroutines.NonCancellable
1111
import kotlinx.coroutines.suspendCancellableCoroutine

‎src/main/kotlin/com/github/viartemev/rabbitmq/rpc/RpcQueueSpecification.kt renamed to ‎src/main/kotlin/io/github/viartemev/rabbitmq/rpc/RpcQueueSpecification.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package com.github.viartemev.rabbitmq.rpc
1+
package io.github.viartemev.rabbitmq.rpc
22

3-
import com.github.viartemev.rabbitmq.queue.QueueSpecification
3+
import io.github.viartemev.rabbitmq.queue.QueueSpecification
44

55

66
object RpcQueueSpecification : QueueSpecification(

‎src/test/kotlin/com/github/viartemev/rabbitmq/rpc/RpcTest1.kt

-67
This file was deleted.

‎src/test/kotlin/com/github/viartemev/rabbitmq/AbstractTestContainersTest.kt renamed to ‎src/test/kotlin/io/github/viartemev/rabbitmq/AbstractTestContainersTest.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.github.viartemev.rabbitmq
1+
package io.github.viartemev.rabbitmq
22

3-
import com.github.viartemev.rabbitmq.utils.RabbitMQContainer
43
import com.rabbitmq.client.Connection
54
import com.rabbitmq.client.ConnectionFactory
65
import com.rabbitmq.http.client.Client
6+
import io.github.viartemev.rabbitmq.utils.RabbitMQContainer
77
import org.junit.jupiter.api.BeforeAll
88
import org.junit.jupiter.api.TestInstance
99
import org.testcontainers.junit.jupiter.Container

‎src/test/kotlin/com/github/viartemev/rabbitmq/channel/TxChannelTest.kt renamed to ‎src/test/kotlin/io/github/viartemev/rabbitmq/channel/TxChannelTest.kt

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.github.viartemev.rabbitmq.channel
1+
package io.github.viartemev.rabbitmq.channel
22

3-
import com.github.viartemev.rabbitmq.AbstractTestContainersTest
4-
import com.github.viartemev.rabbitmq.queue.QueueSpecification
5-
import com.github.viartemev.rabbitmq.queue.declareQueue
6-
import com.github.viartemev.rabbitmq.utils.createMessage
3+
import io.github.viartemev.rabbitmq.AbstractTestContainersTest
4+
import io.github.viartemev.rabbitmq.queue.QueueSpecification
5+
import io.github.viartemev.rabbitmq.queue.declareQueue
6+
import io.github.viartemev.rabbitmq.utils.createMessage
77
import kotlinx.coroutines.CoroutineName
88
import kotlinx.coroutines.delay
99
import kotlinx.coroutines.launch

‎src/test/kotlin/com/github/viartemev/rabbitmq/consumer/ConfirmConsumerTest.kt renamed to ‎src/test/kotlin/io/github/viartemev/rabbitmq/consumer/ConfirmConsumerTest.kt

+8-8
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package com.github.viartemev.rabbitmq.consumer
1+
package io.github.viartemev.rabbitmq.consumer
22

3-
import com.github.viartemev.rabbitmq.AbstractTestContainersTest
4-
import com.github.viartemev.rabbitmq.channel.confirmChannel
5-
import com.github.viartemev.rabbitmq.channel.consume
6-
import com.github.viartemev.rabbitmq.channel.publish
7-
import com.github.viartemev.rabbitmq.queue.QueueSpecification
8-
import com.github.viartemev.rabbitmq.queue.declareQueue
9-
import com.github.viartemev.rabbitmq.utils.createMessage
3+
import io.github.viartemev.rabbitmq.AbstractTestContainersTest
4+
import io.github.viartemev.rabbitmq.channel.confirmChannel
5+
import io.github.viartemev.rabbitmq.channel.consume
6+
import io.github.viartemev.rabbitmq.channel.publish
7+
import io.github.viartemev.rabbitmq.queue.QueueSpecification
8+
import io.github.viartemev.rabbitmq.queue.declareQueue
9+
import io.github.viartemev.rabbitmq.utils.createMessage
1010
import kotlinx.coroutines.*
1111
import org.junit.jupiter.api.Assertions.assertEquals
1212
import org.junit.jupiter.api.Test

‎src/test/kotlin/com/github/viartemev/rabbitmq/consumer/flow/ConsumerFlowTest.kt renamed to ‎src/test/kotlin/io/github/viartemev/rabbitmq/consumer/flow/ConsumerFlowTest.kt

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
package com.github.viartemev.rabbitmq.consumer.flow
1+
package io.github.viartemev.rabbitmq.consumer.flow
22

3-
import com.github.viartemev.rabbitmq.AbstractTestContainersTest
4-
import com.github.viartemev.rabbitmq.channel.channel
5-
import com.github.viartemev.rabbitmq.queue.QueueSpecification
6-
import com.github.viartemev.rabbitmq.queue.declareQueue
73
import com.rabbitmq.client.MessageProperties
4+
import io.github.viartemev.rabbitmq.AbstractTestContainersTest
5+
import io.github.viartemev.rabbitmq.channel.channel
6+
import io.github.viartemev.rabbitmq.queue.QueueSpecification
7+
import io.github.viartemev.rabbitmq.queue.declareQueue
88
import kotlinx.coroutines.Dispatchers
99
import kotlinx.coroutines.coroutineScope
1010
import kotlinx.coroutines.flow.catch

‎src/test/kotlin/com/github/viartemev/rabbitmq/exchange/ExchangeTest.kt renamed to ‎src/test/kotlin/io/github/viartemev/rabbitmq/exchange/ExchangeTest.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package com.github.viartemev.rabbitmq.exchange
1+
package io.github.viartemev.rabbitmq.exchange
22

3-
import com.github.viartemev.rabbitmq.AbstractTestContainersTest
3+
import io.github.viartemev.rabbitmq.AbstractTestContainersTest
44
import kotlinx.coroutines.runBlocking
55
import org.junit.jupiter.api.Assertions.assertNotNull
66
import org.junit.jupiter.api.Assertions.assertNull

0 commit comments

Comments
 (0)