diff --git a/sdk/go/rabbitmq/getExchange.go b/sdk/go/rabbitmq/getExchange.go
index 8b495466..53b24431 100644
--- a/sdk/go/rabbitmq/getExchange.go
+++ b/sdk/go/rabbitmq/getExchange.go
@@ -37,14 +37,20 @@ type LookupExchangeResult struct {
 
 func LookupExchangeOutput(ctx *pulumi.Context, args LookupExchangeOutputArgs, opts ...pulumi.InvokeOption) LookupExchangeResultOutput {
 	return pulumi.ToOutputWithContext(context.Background(), args).
-		ApplyT(func(v interface{}) (LookupExchangeResult, error) {
+		ApplyT(func(v interface{}) (LookupExchangeResultOutput, error) {
 			args := v.(LookupExchangeArgs)
-			r, err := LookupExchange(ctx, &args, opts...)
-			var s LookupExchangeResult
-			if r != nil {
-				s = *r
+			opts = internal.PkgInvokeDefaultOpts(opts)
+			var rv LookupExchangeResult
+			secret, err := ctx.InvokePackageRaw("rabbitmq:index/getExchange:getExchange", args, &rv, "", opts...)
+			if err != nil {
+				return LookupExchangeResultOutput{}, err
 			}
-			return s, err
+
+			output := pulumi.ToOutput(rv).(LookupExchangeResultOutput)
+			if secret {
+				return pulumi.ToSecret(output).(LookupExchangeResultOutput), nil
+			}
+			return output, nil
 		}).(LookupExchangeResultOutput)
 }
 
diff --git a/sdk/go/rabbitmq/getUser.go b/sdk/go/rabbitmq/getUser.go
index b4523c20..f94ddbf3 100644
--- a/sdk/go/rabbitmq/getUser.go
+++ b/sdk/go/rabbitmq/getUser.go
@@ -35,14 +35,20 @@ type LookupUserResult struct {
 
 func LookupUserOutput(ctx *pulumi.Context, args LookupUserOutputArgs, opts ...pulumi.InvokeOption) LookupUserResultOutput {
 	return pulumi.ToOutputWithContext(context.Background(), args).
-		ApplyT(func(v interface{}) (LookupUserResult, error) {
+		ApplyT(func(v interface{}) (LookupUserResultOutput, error) {
 			args := v.(LookupUserArgs)
-			r, err := LookupUser(ctx, &args, opts...)
-			var s LookupUserResult
-			if r != nil {
-				s = *r
+			opts = internal.PkgInvokeDefaultOpts(opts)
+			var rv LookupUserResult
+			secret, err := ctx.InvokePackageRaw("rabbitmq:index/getUser:getUser", args, &rv, "", opts...)
+			if err != nil {
+				return LookupUserResultOutput{}, err
 			}
-			return s, err
+
+			output := pulumi.ToOutput(rv).(LookupUserResultOutput)
+			if secret {
+				return pulumi.ToSecret(output).(LookupUserResultOutput), nil
+			}
+			return output, nil
 		}).(LookupUserResultOutput)
 }
 
diff --git a/sdk/go/rabbitmq/getVHost.go b/sdk/go/rabbitmq/getVHost.go
index d3639571..c247d491 100644
--- a/sdk/go/rabbitmq/getVHost.go
+++ b/sdk/go/rabbitmq/getVHost.go
@@ -34,14 +34,20 @@ type LookupVHostResult struct {
 
 func LookupVHostOutput(ctx *pulumi.Context, args LookupVHostOutputArgs, opts ...pulumi.InvokeOption) LookupVHostResultOutput {
 	return pulumi.ToOutputWithContext(context.Background(), args).
-		ApplyT(func(v interface{}) (LookupVHostResult, error) {
+		ApplyT(func(v interface{}) (LookupVHostResultOutput, error) {
 			args := v.(LookupVHostArgs)
-			r, err := LookupVHost(ctx, &args, opts...)
-			var s LookupVHostResult
-			if r != nil {
-				s = *r
+			opts = internal.PkgInvokeDefaultOpts(opts)
+			var rv LookupVHostResult
+			secret, err := ctx.InvokePackageRaw("rabbitmq:index/getVHost:getVHost", args, &rv, "", opts...)
+			if err != nil {
+				return LookupVHostResultOutput{}, err
 			}
-			return s, err
+
+			output := pulumi.ToOutput(rv).(LookupVHostResultOutput)
+			if secret {
+				return pulumi.ToSecret(output).(LookupVHostResultOutput), nil
+			}
+			return output, nil
 		}).(LookupVHostResultOutput)
 }
 
diff --git a/sdk/java/build.gradle b/sdk/java/build.gradle
index c7951753..5a8e27d8 100644
--- a/sdk/java/build.gradle
+++ b/sdk/java/build.gradle
@@ -44,7 +44,7 @@ repositories {
 dependencies {
     implementation("com.google.code.findbugs:jsr305:3.0.2")
     implementation("com.google.code.gson:gson:2.8.9")
-    implementation("com.pulumi:pulumi:0.15.0")
+    implementation("com.pulumi:pulumi:0.16.1")
 }
 
 task sourcesJar(type: Jar) {
diff --git a/sdk/nodejs/getExchange.ts b/sdk/nodejs/getExchange.ts
index 646354e4..b5ba1312 100644
--- a/sdk/nodejs/getExchange.ts
+++ b/sdk/nodejs/getExchange.ts
@@ -7,7 +7,6 @@ import * as outputs from "./types/output";
 import * as utilities from "./utilities";
 
 export function getExchange(args: GetExchangeArgs, opts?: pulumi.InvokeOptions): Promise<GetExchangeResult> {
-
     opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts || {});
     return pulumi.runtime.invoke("rabbitmq:index/getExchange:getExchange", {
         "name": args.name,
@@ -33,7 +32,11 @@ export interface GetExchangeResult {
     readonly vhost?: string;
 }
 export function getExchangeOutput(args: GetExchangeOutputArgs, opts?: pulumi.InvokeOptions): pulumi.Output<GetExchangeResult> {
-    return pulumi.output(args).apply((a: any) => getExchange(a, opts))
+    opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts || {});
+    return pulumi.runtime.invokeOutput("rabbitmq:index/getExchange:getExchange", {
+        "name": args.name,
+        "vhost": args.vhost,
+    }, opts);
 }
 
 /**
diff --git a/sdk/nodejs/getUser.ts b/sdk/nodejs/getUser.ts
index fb7a679c..6fdd2c91 100644
--- a/sdk/nodejs/getUser.ts
+++ b/sdk/nodejs/getUser.ts
@@ -5,7 +5,6 @@ import * as pulumi from "@pulumi/pulumi";
 import * as utilities from "./utilities";
 
 export function getUser(args: GetUserArgs, opts?: pulumi.InvokeOptions): Promise<GetUserResult> {
-
     opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts || {});
     return pulumi.runtime.invoke("rabbitmq:index/getUser:getUser", {
         "name": args.name,
@@ -28,7 +27,10 @@ export interface GetUserResult {
     readonly tags: string[];
 }
 export function getUserOutput(args: GetUserOutputArgs, opts?: pulumi.InvokeOptions): pulumi.Output<GetUserResult> {
-    return pulumi.output(args).apply((a: any) => getUser(a, opts))
+    opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts || {});
+    return pulumi.runtime.invokeOutput("rabbitmq:index/getUser:getUser", {
+        "name": args.name,
+    }, opts);
 }
 
 /**
diff --git a/sdk/nodejs/getVHost.ts b/sdk/nodejs/getVHost.ts
index 902fef8c..a503569e 100644
--- a/sdk/nodejs/getVHost.ts
+++ b/sdk/nodejs/getVHost.ts
@@ -5,7 +5,6 @@ import * as pulumi from "@pulumi/pulumi";
 import * as utilities from "./utilities";
 
 export function getVHost(args: GetVHostArgs, opts?: pulumi.InvokeOptions): Promise<GetVHostResult> {
-
     opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts || {});
     return pulumi.runtime.invoke("rabbitmq:index/getVHost:getVHost", {
         "name": args.name,
@@ -27,7 +26,10 @@ export interface GetVHostResult {
     readonly name: string;
 }
 export function getVHostOutput(args: GetVHostOutputArgs, opts?: pulumi.InvokeOptions): pulumi.Output<GetVHostResult> {
-    return pulumi.output(args).apply((a: any) => getVHost(a, opts))
+    opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts || {});
+    return pulumi.runtime.invokeOutput("rabbitmq:index/getVHost:getVHost", {
+        "name": args.name,
+    }, opts);
 }
 
 /**