add logs
This commit is contained in:
+2
-2
@@ -23,11 +23,11 @@ export function getAmpqUrl(config): string {
|
||||
}
|
||||
const u = encodeURIComponent(config.user);
|
||||
const p = encodeURIComponent(config.pass);
|
||||
const v = encodeURIComponent(config.vhost)
|
||||
const v = encodeURIComponent(config.vhost);
|
||||
console.log(`max frame: ${frameMaxValue}`);
|
||||
return `amqp://${u}:${p}@${config.host}/${v}?frameMax=${frameMaxValue}`;
|
||||
}
|
||||
|
||||
|
||||
async function createChannels(connection) {
|
||||
try {
|
||||
const channel = await connection.createChannel();
|
||||
|
||||
@@ -529,6 +529,8 @@ export default class MainDSWorker extends HyperionWorker {
|
||||
|
||||
routeToPool(trace, headers) {
|
||||
|
||||
console.log(headers.block_num, headers.signatures);
|
||||
|
||||
let first_action;
|
||||
if (trace['action_traces'][0] && trace['action_traces'][0].length === 2) {
|
||||
first_action = trace['action_traces'][0][1];
|
||||
|
||||
Reference in New Issue
Block a user