Skip to content

Commit

Permalink
Fix package name for java and kotlin (#85)
Browse files Browse the repository at this point in the history
* fix: package name for java and kotlin

* feat: sbt version

Co-authored-by: al.terekhov <[email protected]>
  • Loading branch information
aiterekhov and al.terekhov authored Jan 10, 2023
1 parent 171785a commit 939a8e2
Show file tree
Hide file tree
Showing 30 changed files with 59 additions and 57 deletions.
12 changes: 6 additions & 6 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -45,12 +45,12 @@ gatling("ru.tinkoff:gatling-amqp-plugin_2.13:<version>")

### Java

* Example scenario for [publishing](src/test/java/ru/tinkoff/gatling/javaapi/amqp/examples/PublishExample.java)
* Example scenario for [Publish And Reply](src/test/java/ru/tinkoff/gatling/javaapi/amqp/examples/RequestReplyExample.java)
* Example scenario for [Publish and Reply on different message-brokers](src/test/java/ru/tinkoff/gatling/javaapi/amqp/examples/RequestReplyTwoBrokerExample.java)
* Example scenario for [publishing](src/test/java/ru/tinkoff/gatling/amqp/javaapi/examples/PublishExample.java)
* Example scenario for [Publish And Reply](src/test/java/ru/tinkoff/gatling/amqp/javaapi/examples/RequestReplyExample.java)
* Example scenario for [Publish and Reply on different message-brokers](src/test/java/ru/tinkoff/gatling/amqp/javaapi/examples/RequestReplyTwoBrokerExample.java)

### Kotlin

* Example scenario for [publishing](src/test/kotlin/ru/tinkoff/gatling/javaapi/amqp/examples/PublishExample.kt)
* Example scenario for [Publish And Reply](src/test/kotlin/ru/tinkoff/gatling/javaapi/amqp/examples/RequestReplyExample.kt)
* Example scenario for [Publish and Reply on different message-brokers](src/test/kotlin/ru/tinkoff/gatling/javaapi/amqp/examples/RequestReplyTwoBrokerExample.kt)
* Example scenario for [publishing](src/test/kotlin/ru/tinkoff/gatling/amqp/javaapi/examples/PublishExample.kt)
* Example scenario for [Publish And Reply](src/test/kotlin/ru/tinkoff/gatling/amqp/javaapi/examples/RequestReplyExample.kt)
* Example scenario for [Publish and Reply on different message-brokers](src/test/kotlin/ru/tinkoff/gatling/amqp/javaapi/examples/RequestReplyTwoBrokerExample.kt)
2 changes: 1 addition & 1 deletion project/build.properties
Original file line number Diff line number Diff line change
@@ -1 +1 @@
sbt.version=1.7.3
sbt.version=1.8.2
Original file line number Diff line number Diff line change
@@ -1,13 +1,15 @@
package ru.tinkoff.gatling.javaapi;
package ru.tinkoff.gatling.amqp.javaapi;

import static io.gatling.javaapi.core.internal.Expressions.*;

import ru.tinkoff.gatling.amqp.checks.AmqpResponseCodeCheckBuilder;
import ru.tinkoff.gatling.amqp.javaapi.check.ExtendedCheckBuilder;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpProtocolBuilderBase;
import ru.tinkoff.gatling.amqp.javaapi.protocol.RabbitMQConnectionFactoryBuilderBase;
import ru.tinkoff.gatling.amqp.request.AmqpProtocolMessage;
import ru.tinkoff.gatling.javaapi.check.AmqpChecks;
import ru.tinkoff.gatling.javaapi.check.ExtendedCheckBuilder;
import ru.tinkoff.gatling.javaapi.protocol.*;
import ru.tinkoff.gatling.javaapi.request.AmqpDslBuilderBase;
import ru.tinkoff.gatling.amqp.javaapi.check.AmqpChecks;
import ru.tinkoff.gatling.amqp.javaapi.protocol.*;
import ru.tinkoff.gatling.amqp.javaapi.request.AmqpDslBuilderBase;
import scala.Function1;

public final class AmqpDsl {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.check;
package ru.tinkoff.gatling.amqp.javaapi.check;

import io.gatling.javaapi.core.CheckBuilder;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.check
package ru.tinkoff.gatling.amqp.javaapi.check

import com.fasterxml.jackson.databind.JsonNode
import io.gatling.core.check._
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.check;
package ru.tinkoff.gatling.amqp.javaapi.check;

import io.gatling.core.check.CheckBuilder;
import ru.tinkoff.gatling.amqp.checks.AmqpResponseCodeCheckBuilder.AmqpMessageCheckType;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.check;
package ru.tinkoff.gatling.amqp.javaapi.check;

import ru.tinkoff.gatling.amqp.checks.AmqpResponseCodeCheckBuilder.*;
import ru.tinkoff.gatling.amqp.request.AmqpProtocolMessage;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.protocol;
package ru.tinkoff.gatling.amqp.javaapi.protocol;

import com.rabbitmq.client.BuiltinExchangeType;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.protocol;
package ru.tinkoff.gatling.amqp.javaapi.protocol;

import io.gatling.core.protocol.Protocol;
import io.gatling.javaapi.core.ProtocolBuilder;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.protocol;
package ru.tinkoff.gatling.amqp.javaapi.protocol;

import com.rabbitmq.client.ConnectionFactory;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.protocol;
package ru.tinkoff.gatling.amqp.javaapi.protocol;

import java.util.Map;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.protocol;
package ru.tinkoff.gatling.amqp.javaapi.protocol;

import com.rabbitmq.client.ConnectionFactory;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.protocol;
package ru.tinkoff.gatling.amqp.javaapi.protocol;

import scala.Option;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

public final class AmqpDslBuilderBase {
private final ru.tinkoff.gatling.amqp.request.AmqpDslBuilderBase wrapped;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

import java.util.Map;
import static io.gatling.javaapi.core.internal.Expressions.*;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

import static io.gatling.javaapi.core.internal.Expressions.*;
public class PublishDslBuilderExchange {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

import java.nio.charset.Charset;
import static io.gatling.javaapi.core.internal.Expressions.*;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

import io.gatling.javaapi.core.ActionBuilder;
import ru.tinkoff.gatling.javaapi.check.AmqpChecks;
import ru.tinkoff.gatling.amqp.javaapi.check.AmqpChecks;
import scala.Tuple2;

import java.util.Arrays;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

import static io.gatling.javaapi.core.internal.Expressions.*;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.request;
package ru.tinkoff.gatling.amqp.javaapi.request;

import java.nio.charset.Charset;
import java.util.ArrayList;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package ru.tinkoff.gatling.javaapi.amqp.examples;
package ru.tinkoff.gatling.amqp.javaapi.examples;

import io.gatling.javaapi.core.ScenarioBuilder;
import io.gatling.javaapi.core.Simulation;
import ru.tinkoff.gatling.javaapi.protocol.AmqpProtocolBuilder;
import ru.tinkoff.gatling.javaapi.protocol.AmqpQueue;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpProtocolBuilder;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpQueue;

import java.util.Map;

import static io.gatling.javaapi.core.CoreDsl.*;
import static ru.tinkoff.gatling.javaapi.AmqpDsl.*;
import static ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*;

public class PublishExample extends Simulation {

Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,16 @@
package ru.tinkoff.gatling.javaapi.amqp.examples;
package ru.tinkoff.gatling.amqp.javaapi.examples;

import com.rabbitmq.client.BuiltinExchangeType;
import io.gatling.javaapi.core.ScenarioBuilder;
import io.gatling.javaapi.core.Simulation;
import ru.tinkoff.gatling.javaapi.protocol.*;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpExchange;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpProtocolBuilder;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpQueue;

import java.util.Map;

import static io.gatling.javaapi.core.CoreDsl.*;
import static ru.tinkoff.gatling.javaapi.AmqpDsl.*;
import static ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*;

public class RequestReplyExample extends Simulation {
private AmqpExchange topic = new AmqpExchange("test_queue_in", BuiltinExchangeType.TOPIC, false, false, Map.of());
Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package ru.tinkoff.gatling.javaapi.amqp.examples;
package ru.tinkoff.gatling.amqp.javaapi.examples;

import io.gatling.javaapi.core.ScenarioBuilder;
import io.gatling.javaapi.core.Simulation;
import ru.tinkoff.gatling.amqp.examples.utils.SimpleRabbitMQClient;
import ru.tinkoff.gatling.javaapi.protocol.*;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpProtocolBuilder;

import java.util.Map;

import static io.gatling.javaapi.core.CoreDsl.*;
import static ru.tinkoff.gatling.javaapi.AmqpDsl.*;
import static ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*;

public class RequestReplyTwoBrokerExample extends Simulation {

Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package ru.tinkoff.gatling.javaapi.amqp.examples;
package ru.tinkoff.gatling.amqp.javaapi.examples;

import io.gatling.javaapi.core.ScenarioBuilder;
import io.gatling.javaapi.core.Simulation;
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpProtocolBuilder;
import ru.tinkoff.gatling.amqp.request.AmqpProtocolMessage;
import ru.tinkoff.gatling.javaapi.protocol.*;

import java.util.Map;

import static io.gatling.javaapi.core.CoreDsl.*;
import static ru.tinkoff.gatling.javaapi.AmqpDsl.*;
import static ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*;

public class RequestReplyWithOwnMatchingExample extends Simulation {

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ru.tinkoff.gatling.javaapi.amqp.examples;
package ru.tinkoff.gatling.amqp.javaapi.examples;

import java.util.Collections;
import java.util.Iterator;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package ru.tinkoff.gatling.javaapi.aqmp.examples
package ru.tinkoff.gatling.amqp.javaapi.examples

import io.gatling.javaapi.core.CoreDsl.*
import io.gatling.javaapi.core.*
import ru.tinkoff.gatling.javaapi.AmqpDsl.*
import ru.tinkoff.gatling.javaapi.protocol.AmqpProtocolBuilder
import ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*
import ru.tinkoff.gatling.amqp.javaapi.protocol.AmqpProtocolBuilder

class PublishExample : Simulation() {
val amqpConf: AmqpProtocolBuilder = amqp()
Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
package ru.tinkoff.gatling.javaapi.aqmp.examples
package ru.tinkoff.gatling.amqp.javaapi.examples

import com.rabbitmq.client.BuiltinExchangeType
import io.gatling.javaapi.core.CoreDsl.*
import io.gatling.javaapi.core.ScenarioBuilder
import io.gatling.javaapi.core.Simulation
import ru.tinkoff.gatling.amqp.request.AmqpProtocolMessage
import ru.tinkoff.gatling.javaapi.AmqpDsl.*
import ru.tinkoff.gatling.javaapi.protocol.*
import ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*
import ru.tinkoff.gatling.amqp.javaapi.protocol.*

class RequestReplyExample: Simulation(){
private val topic = AmqpExchange("test_queue_in", BuiltinExchangeType.TOPIC, false, false, mapOf())
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,11 @@
package ru.tinkoff.gatling.javaapi.amqp.examples
package ru.tinkoff.gatling.amqp.javaapi.examples

import io.gatling.javaapi.core.CoreDsl
import io.gatling.javaapi.core.CoreDsl.*
import io.gatling.javaapi.core.ScenarioBuilder
import io.gatling.javaapi.core.Simulation
import ru.tinkoff.gatling.javaapi.AmqpDsl
import ru.tinkoff.gatling.javaapi.AmqpDsl.amqp
import ru.tinkoff.load.cosmos.feeders.Feeders

import ru.tinkoff.gatling.amqp.javaapi.AmqpDsl
import ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.amqp

class RequestReplyTwoBrokerExample : Simulation() {
override fun before() {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package ru.tinkoff.gatling.javaapi.amqp.examples
package ru.tinkoff.gatling.amqp.javaapi.examples

import io.gatling.javaapi.core.*
import io.gatling.javaapi.core.CoreDsl.*
import ru.tinkoff.gatling.amqp.request.AmqpProtocolMessage
import ru.tinkoff.gatling.javaapi.AmqpDsl.*
import ru.tinkoff.gatling.amqp.javaapi.AmqpDsl.*

class RequestReplyWithOwnMatchingExample : Simulation() {

Expand Down

0 comments on commit 939a8e2

Please sign in to comment.