You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/04/21 11:45:54 UTC
[camel] branch main updated: CAMEL-16536: digitalocean - suppress
getOut warning (#5448)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new b5f8923 CAMEL-16536: digitalocean - suppress getOut warning (#5448)
b5f8923 is described below
commit b5f8923557ae6bc9b2b159a0c47438b29f8272d0
Author: Zineb BENDHIBA <be...@gmail.com>
AuthorDate: Wed Apr 21 13:45:36 2021 +0200
CAMEL-16536: digitalocean - suppress getOut warning (#5448)
---
.../producer/DigitalOceanAccountProducer.java | 2 +-
.../producer/DigitalOceanActionsProducer.java | 4 +-
.../DigitalOceanBlockStoragesProducer.java | 16 +++---
.../producer/DigitalOceanDropletsProducer.java | 58 +++++++++++-----------
.../producer/DigitalOceanFloatingIPsProducer.java | 14 +++---
.../producer/DigitalOceanImagesProducer.java | 16 +++---
.../producer/DigitalOceanKeysProducer.java | 10 ++--
.../producer/DigitalOceanRegionsProducer.java | 2 +-
.../producer/DigitalOceanSizesProducer.java | 2 +-
.../producer/DigitalOceanSnapshotsProducer.java | 6 +--
.../producer/DigitalOceanTagsProducer.java | 8 +--
11 files changed, 69 insertions(+), 69 deletions(-)
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanAccountProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanAccountProducer.java
index 33b6690..af0fd86 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanAccountProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanAccountProducer.java
@@ -34,7 +34,7 @@ public class DigitalOceanAccountProducer extends DigitalOceanProducer {
public void process(Exchange exchange) throws Exception {
Account accountInfo = getEndpoint().getDigitalOceanClient().getAccountInfo();
LOG.trace("Account [{}] ", accountInfo);
- exchange.getOut().setBody(accountInfo);
+ exchange.getMessage().setBody(accountInfo);
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanActionsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanActionsProducer.java
index 0327eaf..3aa51b8 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanActionsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanActionsProducer.java
@@ -57,7 +57,7 @@ public class DigitalOceanActionsProducer extends DigitalOceanProducer {
}
Action action = getEndpoint().getDigitalOceanClient().getActionInfo(actionId);
LOG.trace("Action [{}] ", action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void getActions(Exchange exchange) throws Exception {
@@ -65,6 +65,6 @@ public class DigitalOceanActionsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("All Actions : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
actions.getActions());
- exchange.getOut().setBody(actions.getActions());
+ exchange.getMessage().setBody(actions.getActions());
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java
index b581e21..1a6de4f 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java
@@ -86,7 +86,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
Volumes volumes = getEndpoint().getDigitalOceanClient().getAvailableVolumes(region);
LOG.trace("All Volumes for region {} [{}] ", region, volumes.getVolumes());
- exchange.getOut().setBody(volumes.getVolumes());
+ exchange.getMessage().setBody(volumes.getVolumes());
}
@@ -121,7 +121,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
volume = getEndpoint().getDigitalOceanClient().createVolume(volume);
LOG.trace("Volume created {}", volume);
- exchange.getOut().setBody(volume);
+ exchange.getMessage().setBody(volume);
}
private void getVolume(Exchange exchange) throws Exception {
@@ -147,7 +147,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
}
LOG.trace("Volume [{}] ", volume);
- exchange.getOut().setBody(volume);
+ exchange.getMessage().setBody(volume);
}
@@ -160,7 +160,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
Snapshots snapshots = getEndpoint().getDigitalOceanClient().getVolumeSnapshots(volumeId, configuration.getPage(),
configuration.getPerPage());
LOG.trace("All Snapshots for volume {} [{}] ", volumeId, snapshots.getSnapshots());
- exchange.getOut().setBody(snapshots.getSnapshots());
+ exchange.getMessage().setBody(snapshots.getSnapshots());
}
private void deleteVolume(Exchange exchange) throws Exception {
@@ -183,7 +183,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
}
LOG.trace("Delete Volume [{}] ", delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
@@ -214,7 +214,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
DigitalOceanHeaders.ID + " or " + DigitalOceanHeaders.VOLUME_NAME + " must be specified");
}
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void detachVolumeToDroplet(Exchange exchange) throws Exception {
@@ -244,7 +244,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
DigitalOceanHeaders.ID + " or " + DigitalOceanHeaders.VOLUME_NAME + " must be specified");
}
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
@@ -280,7 +280,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
Actions actions = getEndpoint().getDigitalOceanClient().getAvailableVolumeActions(volumeId);
LOG.trace("Actions for Volume {} [{}] ", volumeId, actions.getActions());
- exchange.getOut().setBody(actions.getActions());
+ exchange.getMessage().setBody(actions.getActions());
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java
index 82f97a9..b1f7bfe 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java
@@ -160,7 +160,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
private void getDroplet(Exchange exchange) throws Exception {
Droplet droplet = getEndpoint().getDigitalOceanClient().getDropletInfo(dropletId);
LOG.trace("Droplet {}", droplet);
- exchange.getOut().setBody(droplet);
+ exchange.getMessage().setBody(droplet);
}
private void getDroplets(Exchange exchange) throws Exception {
@@ -168,7 +168,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("All Droplets : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
droplets.getDroplets());
- exchange.getOut().setBody(droplets.getDroplets());
+ exchange.getMessage().setBody(droplets.getDroplets());
}
private void getDropletActions(Exchange exchange) throws Exception {
@@ -176,7 +176,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("Actions for Droplet {} : page {} / {} per page [{}] ", dropletId, configuration.getPage(),
configuration.getPerPage(), actions.getActions());
- exchange.getOut().setBody(actions.getActions());
+ exchange.getMessage().setBody(actions.getActions());
}
private void getDropletKernels(Exchange exchange) throws Exception {
@@ -184,7 +184,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("Kernels for Droplet {} : page {} / {} per page [{}] ", dropletId, configuration.getPage(),
configuration.getPerPage(), kernels.getKernels());
- exchange.getOut().setBody(kernels.getKernels());
+ exchange.getMessage().setBody(kernels.getKernels());
}
private void getDropletBackups(Exchange exchange) throws Exception {
@@ -192,7 +192,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("Backups for Droplet {} : page {} / {} per page [{}] ", dropletId, configuration.getPage(),
configuration.getPerPage(), backups.getBackups());
- exchange.getOut().setBody(backups.getBackups());
+ exchange.getMessage().setBody(backups.getBackups());
}
private void getDropletSnapshots(Exchange exchange) throws Exception {
@@ -200,25 +200,25 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("Snapshots for Droplet {} : page {} / {} per page [{}] ", dropletId, configuration.getPage(),
configuration.getPerPage(), snapshots.getSnapshots());
- exchange.getOut().setBody(snapshots.getSnapshots());
+ exchange.getMessage().setBody(snapshots.getSnapshots());
}
private void getDropletNeighbors(Exchange exchange) throws Exception {
Droplets droplets = getEndpoint().getDigitalOceanClient().getDropletNeighbors(dropletId, configuration.getPage());
LOG.trace("Neighbors for Droplet {} : page {} [{}] ", dropletId, configuration.getPage(), droplets.getDroplets());
- exchange.getOut().setBody(droplets.getDroplets());
+ exchange.getMessage().setBody(droplets.getDroplets());
}
private void getAllDropletNeighbors(Exchange exchange) throws Exception {
Neighbors neighbors = getEndpoint().getDigitalOceanClient().getAllDropletNeighbors(configuration.getPage());
LOG.trace("All Neighbors : page {} [{}] ", configuration.getPage(), neighbors.getNeighbors());
- exchange.getOut().setBody(neighbors.getNeighbors());
+ exchange.getMessage().setBody(neighbors.getNeighbors());
}
private void deleteDroplet(Exchange exchange) throws Exception {
Delete delete = getEndpoint().getDigitalOceanClient().deleteDroplet(dropletId);
LOG.trace("Delete Droplet {}", delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
@SuppressWarnings("unchecked")
@@ -279,12 +279,12 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
droplet.setNames((List<String>) in.getHeader(DigitalOceanHeaders.NAMES));
Droplets droplets = getEndpoint().getDigitalOceanClient().createDroplets(droplet);
LOG.trace("Droplets created {}", droplets);
- exchange.getOut().setBody(droplets.getDroplets());
+ exchange.getMessage().setBody(droplets.getDroplets());
} else if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(DigitalOceanHeaders.NAME))) {
droplet.setName(in.getHeader(DigitalOceanHeaders.NAME, String.class));
droplet = getEndpoint().getDigitalOceanClient().createDroplet(droplet);
LOG.trace("Droplet created {}", droplet);
- exchange.getOut().setBody(droplet);
+ exchange.getMessage().setBody(droplet);
} else {
throw new IllegalArgumentException(
DigitalOceanHeaders.NAMES + " or " + DigitalOceanHeaders.NAME + " must be specified");
@@ -300,7 +300,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().restoreDroplet(dropletId,
exchange.getIn().getHeader(DigitalOceanHeaders.IMAGE_ID, Integer.class));
LOG.trace("DropletAction Restore [{}] ", action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
@@ -312,7 +312,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().resizeDroplet(dropletId,
exchange.getIn().getHeader(DigitalOceanHeaders.DROPLET_SIZE, String.class));
LOG.trace("DropletAction Resize [{}] ", action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void rebuildDroplet(Exchange exchange) throws Exception {
@@ -323,7 +323,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().rebuildDroplet(dropletId,
exchange.getIn().getHeader(DigitalOceanHeaders.IMAGE_ID, Integer.class));
LOG.trace("Rebuild Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void renameDroplet(Exchange exchange) throws Exception {
@@ -334,7 +334,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().renameDroplet(dropletId,
exchange.getIn().getHeader(DigitalOceanHeaders.NAME, String.class));
LOG.trace("Rename Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void changeDropletKernel(Exchange exchange) throws Exception {
@@ -345,67 +345,67 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().changeDropletKernel(dropletId,
exchange.getIn().getHeader(DigitalOceanHeaders.KERNEL_ID, Integer.class));
LOG.trace("Change Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void resetDropletPassword(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().resetDropletPassword(dropletId);
LOG.trace("Reset password Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void powerOnDroplet(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().powerOnDroplet(dropletId);
LOG.trace("Power on Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void powerOffDroplet(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().powerOffDroplet(dropletId);
LOG.trace("Power off Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void shutdownDroplet(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().shutdownDroplet(dropletId);
LOG.trace("Shutdown Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void powerCycleDroplet(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().powerCycleDroplet(dropletId);
LOG.trace("Power cycle Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void enableDropletBackups(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().enableDropletBackups(dropletId);
LOG.trace("Enable backups Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void disableDropletBackups(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().disableDropletBackups(dropletId);
LOG.trace("Disable backups for Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void enableDropletIpv6(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().enableDropletIpv6(dropletId);
LOG.trace("Enable IP v6 for Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void enableDropletPrivateNetworking(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().enableDropletPrivateNetworking(dropletId);
LOG.trace("Enable private networking for Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void rebootDroplet(Exchange exchange) throws Exception {
Action action = getEndpoint().getDigitalOceanClient().rebootDroplet(dropletId);
LOG.trace("Reboot Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void takeDropletSnapshot(Exchange exchange) throws Exception {
@@ -419,7 +419,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
}
LOG.trace("Take Snapshot for Droplet {} : [{}] ", dropletId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void tagDroplet(Exchange exchange) throws Exception {
@@ -431,7 +431,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
resources.add(new Resource(dropletId.toString(), ResourceType.DROPLET));
Response response = getEndpoint().getDigitalOceanClient().tagResources(dropletId.toString(), resources);
LOG.trace("Tag Droplet {} : [{}] ", dropletId, response);
- exchange.getOut().setBody(response);
+ exchange.getMessage().setBody(response);
}
private void untagDroplet(Exchange exchange) throws Exception {
@@ -443,7 +443,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
resources.add(new Resource(dropletId.toString(), ResourceType.DROPLET));
Response response = getEndpoint().getDigitalOceanClient().untagResources(dropletId.toString(), resources);
LOG.trace("Untag Droplet {} : [{}] ", dropletId, response);
- exchange.getOut().setBody(response);
+ exchange.getMessage().setBody(response);
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java
index 2a19004..fb133db 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java
@@ -81,7 +81,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
}
LOG.trace("FloatingIP [{}] ", ip);
- exchange.getOut().setBody(ip);
+ exchange.getMessage().setBody(ip);
}
private void getFloatingIPs(Exchange exchange) throws Exception {
@@ -89,7 +89,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("All Floating IPs : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
ips.getFloatingIPs());
- exchange.getOut().setBody(ips.getFloatingIPs());
+ exchange.getMessage().setBody(ips.getFloatingIPs());
}
private void getFloatingIP(Exchange exchange) throws Exception {
@@ -101,7 +101,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
FloatingIP ip = getEndpoint().getDigitalOceanClient().getFloatingIPInfo(ipAddress);
LOG.trace("Floating IP {}", ip);
- exchange.getOut().setBody(ip);
+ exchange.getMessage().setBody(ip);
}
private void deleteFloatingIP(Exchange exchange) throws Exception {
@@ -113,7 +113,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
Delete delete = getEndpoint().getDigitalOceanClient().deleteFloatingIP(ipAddress);
LOG.trace("Delete Floating IP {}", delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
private void assignFloatingIPToDroplet(Exchange exchange) throws Exception {
@@ -131,7 +131,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().assignFloatingIP(dropletId, ipAddress);
LOG.trace("Assign Floating IP to Droplet {}", action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void unassignFloatingIP(Exchange exchange) throws Exception {
@@ -143,7 +143,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().unassignFloatingIP(ipAddress);
LOG.trace("Unassign Floating IP {}", action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void getFloatingIPActions(Exchange exchange) throws Exception {
@@ -157,7 +157,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
configuration.getPage(), configuration.getPerPage());
LOG.trace("Actions for FloatingIP {} : page {} / {} per page [{}] ", ipAddress, configuration.getPage(),
configuration.getPerPage(), actions.getActions());
- exchange.getOut().setBody(actions.getActions());
+ exchange.getMessage().setBody(actions.getActions());
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanImagesProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanImagesProducer.java
index 83e8a34..336fd3e 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanImagesProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanImagesProducer.java
@@ -77,7 +77,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
= getEndpoint().getDigitalOceanClient().getUserImages(configuration.getPage(), configuration.getPerPage());
LOG.trace("User images : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
images.getImages());
- exchange.getOut().setBody(images.getImages());
+ exchange.getMessage().setBody(images.getImages());
}
private void getImages(Exchange exchange) throws Exception {
@@ -93,7 +93,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
}
LOG.trace("All Images : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
images.getImages());
- exchange.getOut().setBody(images.getImages());
+ exchange.getMessage().setBody(images.getImages());
}
private void getImage(Exchange exchange) throws Exception {
@@ -112,7 +112,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
}
LOG.trace("Image [{}] ", image);
- exchange.getOut().setBody(image);
+ exchange.getMessage().setBody(image);
}
private void getImageActions(Exchange exchange) throws Exception {
@@ -126,7 +126,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
configuration.getPerPage());
LOG.trace("Actions for Image {} : page {} / {} per page [{}] ", imageId, configuration.getPage(),
configuration.getPerPage(), actions.getActions());
- exchange.getOut().setBody(actions.getActions());
+ exchange.getMessage().setBody(actions.getActions());
}
private void updateImage(Exchange exchange) throws Exception {
@@ -146,7 +146,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
image.setName(name);
image = getEndpoint().getDigitalOceanClient().updateImage(image);
LOG.trace("Update Image {} [{}] ", imageId, image);
- exchange.getOut().setBody(image);
+ exchange.getMessage().setBody(image);
}
private void deleteImage(Exchange exchange) throws Exception {
@@ -158,7 +158,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
Delete delete = getEndpoint().getDigitalOceanClient().deleteImage(imageId);
LOG.trace("Delete Image {} [{}] ", imageId, delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
private void transferImage(Exchange exchange) throws Exception {
@@ -176,7 +176,7 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().transferImage(imageId, region);
LOG.trace("Transfer Image {} to Region {} [{}] ", imageId, region, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
private void convertImageToSnapshot(Exchange exchange) throws Exception {
@@ -188,6 +188,6 @@ public class DigitalOceanImagesProducer extends DigitalOceanProducer {
Action action = getEndpoint().getDigitalOceanClient().convertImage(imageId);
LOG.trace("Convert Image {} [{}] ", imageId, action);
- exchange.getOut().setBody(action);
+ exchange.getMessage().setBody(action);
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java
index 6799726..7cf794d 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java
@@ -73,13 +73,13 @@ public class DigitalOceanKeysProducer extends DigitalOceanProducer {
DigitalOceanHeaders.ID + " or " + DigitalOceanHeaders.KEY_FINGERPRINT + " must be specified");
}
LOG.trace("Key [{}] ", key);
- exchange.getOut().setBody(key);
+ exchange.getMessage().setBody(key);
}
private void getKeys(Exchange exchange) throws Exception {
Keys keys = getEndpoint().getDigitalOceanClient().getAvailableKeys(configuration.getPage());
LOG.trace("All Keys : page {} [{}] ", configuration.getPage(), keys.getKeys());
- exchange.getOut().setBody(keys.getKeys());
+ exchange.getMessage().setBody(keys.getKeys());
}
private void deleteKey(Exchange exchange) throws Exception {
@@ -97,7 +97,7 @@ public class DigitalOceanKeysProducer extends DigitalOceanProducer {
}
LOG.trace("Delete Key {}", delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
private void createKey(Exchange exchange) throws Exception {
@@ -122,7 +122,7 @@ public class DigitalOceanKeysProducer extends DigitalOceanProducer {
key = getEndpoint().getDigitalOceanClient().createKey(key);
LOG.trace("Key created {}", key);
- exchange.getOut().setBody(key);
+ exchange.getMessage().setBody(key);
}
@@ -147,7 +147,7 @@ public class DigitalOceanKeysProducer extends DigitalOceanProducer {
}
LOG.trace("Update Key [{}] ", key);
- exchange.getOut().setBody(key);
+ exchange.getMessage().setBody(key);
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanRegionsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanRegionsProducer.java
index fd758b5..1b811f9 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanRegionsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanRegionsProducer.java
@@ -34,7 +34,7 @@ public class DigitalOceanRegionsProducer extends DigitalOceanProducer {
public void process(Exchange exchange) throws Exception {
Regions regions = getEndpoint().getDigitalOceanClient().getAvailableRegions(configuration.getPage());
LOG.trace("All Regions : page {} [{}] ", regions.getRegions(), configuration.getPage());
- exchange.getOut().setBody(regions.getRegions());
+ exchange.getMessage().setBody(regions.getRegions());
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSizesProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSizesProducer.java
index ed5f051..8240c1e 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSizesProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSizesProducer.java
@@ -34,7 +34,7 @@ public class DigitalOceanSizesProducer extends DigitalOceanProducer {
public void process(Exchange exchange) throws Exception {
Sizes sizes = getEndpoint().getDigitalOceanClient().getAvailableSizes(configuration.getPage());
LOG.trace("All Sizes : page {} [{}] ", sizes.getSizes(), configuration.getPage());
- exchange.getOut().setBody(sizes.getSizes());
+ exchange.getMessage().setBody(sizes.getSizes());
}
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSnapshotsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSnapshotsProducer.java
index bdf2fc6..783cbdf 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSnapshotsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanSnapshotsProducer.java
@@ -75,7 +75,7 @@ public class DigitalOceanSnapshotsProducer extends DigitalOceanProducer {
LOG.trace("All Snapshots : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
snapshots.getSnapshots());
- exchange.getOut().setBody(snapshots.getSnapshots());
+ exchange.getMessage().setBody(snapshots.getSnapshots());
}
private void getSnapshot(Exchange exchange) throws Exception {
@@ -87,7 +87,7 @@ public class DigitalOceanSnapshotsProducer extends DigitalOceanProducer {
Snapshot snapshot = getEndpoint().getDigitalOceanClient().getSnaphotInfo(snapshotId);
LOG.trace("Snapshot [{}] ", snapshot);
- exchange.getOut().setBody(snapshot);
+ exchange.getMessage().setBody(snapshot);
}
@@ -100,7 +100,7 @@ public class DigitalOceanSnapshotsProducer extends DigitalOceanProducer {
Delete delete = getEndpoint().getDigitalOceanClient().deleteSnapshot(snapshotId);
LOG.trace("Delete Snapshot [{}] ", delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanTagsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanTagsProducer.java
index 9016aaf..472b63c 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanTagsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanTagsProducer.java
@@ -63,7 +63,7 @@ public class DigitalOceanTagsProducer extends DigitalOceanProducer {
}
Tag tag = getEndpoint().getDigitalOceanClient().createTag(name);
LOG.trace("Create Tag [{}] ", tag);
- exchange.getOut().setBody(tag);
+ exchange.getMessage().setBody(tag);
}
private void getTag(Exchange exchange) throws Exception {
@@ -74,14 +74,14 @@ public class DigitalOceanTagsProducer extends DigitalOceanProducer {
}
Tag tag = getEndpoint().getDigitalOceanClient().getTag(name);
LOG.trace("Tag [{}] ", tag);
- exchange.getOut().setBody(tag);
+ exchange.getMessage().setBody(tag);
}
private void getTags(Exchange exchange) throws Exception {
Tags tags = getEndpoint().getDigitalOceanClient().getAvailableTags(configuration.getPage(), configuration.getPerPage());
LOG.trace("All Tags : page {} / {} per page [{}] ", configuration.getPage(), configuration.getPerPage(),
tags.getTags());
- exchange.getOut().setBody(tags.getTags());
+ exchange.getMessage().setBody(tags.getTags());
}
private void deleteTag(Exchange exchange) throws Exception {
@@ -92,7 +92,7 @@ public class DigitalOceanTagsProducer extends DigitalOceanProducer {
}
Delete delete = getEndpoint().getDigitalOceanClient().deleteTag(name);
LOG.trace("Delete Tag [{}] ", delete);
- exchange.getOut().setBody(delete);
+ exchange.getMessage().setBody(delete);
}
}